MCPcopy Create free account

hub / github.com/HappyWjl/es-home / functions

Functions176 in github.com/HappyWjl/es-home

↓ 20 callersMethodbuildSuccessResult
(U value)
stone/src/main/java/com/es/stone/result/BaseResult.java:28
↓ 15 callersMethodgetValue
()
stone/src/main/java/com/es/stone/result/BaseResult.java:12
↓ 6 callersMethodgetElasticClient
()
stone/src/main/java/com/es/stone/manager/ElasticSearchInitClientManager.java:27
↓ 6 callersMethodtoCamelCase
驼峰转下划线 @param str @return
stone/src/main/java/com/es/stone/util/CamelCaseUtils.java:42
↓ 5 callersMethodinsertOrUpdateToEs
同步插入或更新ES数据方法 @param colMap @param index
stone/src/main/java/com/es/stone/manager/ElasticSearchDumpManager.java:61
↓ 5 callersMethodtoUnderlineName
下划线转驼峰 @param str @return
stone/src/main/java/com/es/stone/util/CamelCaseUtils.java:10
↓ 4 callersMethodgetConnection
获取数据库链接 @param driver @param url @param name @param pwd @return
data-back/src/main/java/com/es/databack/util/DatabaseUtil.java:17
↓ 3 callersMethodindex
获取索引类型列表 @return
data-back/src/main/java/com/es/databack/controller/ConstantController.java:88
↓ 3 callersMethodrun
(String... args)
data-dump/src/main/java/com/es/datadump/run/CanalClientRunner.java:33
↓ 2 callersMethodapiInfo
()
data-back/src/main/java/com/es/databack/configuration/Swagger2Config.java:29
↓ 2 callersMethodapiInfo
()
data-migration/src/main/java/com/es/datamigration/configuration/Swagger2Config.java:29
↓ 2 callersMethodbuildPositionForDump
(Entry entry)
data-dump/src/main/java/com/es/datadump/manager/canal/AbstractCanalCoreManager.java:162
↓ 2 callersMethodcheckIndex
检查索引相关配置 @return
data-back/src/main/java/com/es/databack/controller/CheckController.java:42
↓ 2 callersMethodconvertDate
(Map mapDTO)
data-search/src/main/java/com/es/datasearch/util/ConvertDateUtil.java:23
↓ 2 callersMethodgenFileDir
转换java文件头部文案 @param dir @param params @return
data-back/src/main/java/com/es/databack/util/FileHelper.java:59
↓ 2 callersMethodgetDesc
()
stone/src/main/java/com/es/stone/enums/EsStatus.java:16
↓ 2 callersMethodinitClientPool
初始化ES连接池 连接池有上限,若连接池满,则阻塞等待占用的线程释放ES客户端连接。 一旦连接被释放,池中存在空闲客户端,即可继续被消费。
stone/src/main/java/com/es/stone/manager/ElasticSearchInitClientManager.java:75
↓ 2 callersMethodisExistsIndex
判断索引是否存在,通用方法 @param index @return @throws Exception
stone/src/main/java/com/es/stone/manager/ElasticSearchDumpManager.java:149
↓ 2 callersMethodload
(List<T> data, int totalCount)
stone/src/main/java/com/es/stone/util/WebPager.java:16
↓ 2 callersMethodprocess
()
data-dump/src/main/java/com/es/datadump/manager/canal/AbstractCanalCoreManager.java:111
↓ 2 callersMethodserverToHttpHost
(String servers)
stone/src/main/java/com/es/stone/manager/ElasticSearchInitClientManager.java:41
↓ 1 callersMethodanalysisColumn
解析mysql的binlog方法,返回key列名和值value @param columns @return
data-dump/src/main/java/com/es/datadump/manager/canal/AbstractCanalCoreManager.java:205
↓ 1 callersMethodarticleListInfoDump
根据article表同步数据 @param colMap @param index
data-migration/src/main/java/com/es/datamigration/manager/ServiceImportManager.java:59
↓ 1 callersMethodbuildMobilePager
( List<T> data, Function<T, Long> anchorIdFunc, int pageSize, boolean getAnchorIdByLast)
stone/src/main/java/com/es/stone/util/Pagers.java:23
↓ 1 callersMethodbuildWebPager
( List<T> data, int pageSize, int currentPage, int totalCount)
stone/src/main/java/com/es/stone/util/Pagers.java:14
↓ 1 callersMethodbuilderArticleSquareCondition
组装文章查询逻辑 @param queryArticleSearchVO @return
data-search/src/main/java/com/es/datasearch/manager/tbArticle/ArticleSearchManager.java:104
↓ 1 callersMethodbytesToString
(byte[] input, String sourceCharSet,String destCharSet)
data-dump/src/main/java/com/es/datadump/util/CharSetUtil.java:13
↓ 1 callersMethodcall
()
data-dump/src/main/java/com/es/datadump/manager/canal/AbstractCanalCoreManager.java:286
↓ 1 callersMethodcheckColumn
(String tableName, String[] columns)
data-back/src/main/java/com/es/databack/controller/CheckController.java:187
↓ 1 callersMethodcheckIndexType
(String[] columns, String[] indexTypes)
data-back/src/main/java/com/es/databack/controller/CheckController.java:203
↓ 1 callersMethodcheckTable
(Connection conn, String tableName)
data-back/src/main/java/com/es/databack/controller/CheckController.java:115
↓ 1 callersMethodconvertArray
(String str)
stone/src/main/java/com/es/stone/converter/ArrayConverter.java:5
↓ 1 callersMethodconvertTbArticle
db_search.tb_article创建逻辑 @param index @return
stone/src/main/java/com/es/stone/manager/ElasticSearchIndexManager.java:25
↓ 1 callersMethodconvertToMap
(TbArticleDO tbArticleDO)
data-migration/src/main/java/com/es/datamigration/util/ConvertMapUtil.java:13
↓ 1 callersMethodcreateIndex
根据配置创建索引,通用方法 @param createRequest @return @throws Exception
stone/src/main/java/com/es/stone/manager/ElasticSearchDumpManager.java:137
↓ 1 callersMethodcreateIndexRequest
配置索引请求规则 @param index @return
data-back/src/main/java/com/es/databack/controller/CreateController.java:113
↓ 1 callersMethoddeleteRecordToEs
同步删除ES数据方法 @param colMap @param index
stone/src/main/java/com/es/stone/manager/ElasticSearchDumpManager.java:45
↓ 1 callersMethoddisConnect
(RestHighLevelClient client)
stone/src/main/java/com/es/stone/manager/ElasticSearchInitClientManager.java:110
↓ 1 callersMethodesKeyString
排序组装es的id,兼容联合主键 @param keyMap @return
stone/src/main/java/com/es/stone/manager/ElasticSearchDumpManager.java:31
↓ 1 callersMethodfindAllFile
根据路径搜索所有文件 @param file @return
data-back/src/main/java/com/es/databack/util/FileHelper.java:18
↓ 1 callersMethodgen
<p>Discription:[生成映射文件和实体类]</p> Created on 2019年4月4日 @param dbName 要声称映射文件和实体类的库名称 @param tableName 要声称映射文件和实体类的表名称 @param tableDescAn
data-back/src/main/java/com/es/databack/controller/CreateController.java:228
↓ 1 callersMethodgetArticleList
(QueryArticleSearchVO queryArticleSearchVO)
data-search/src/main/java/com/es/datasearch/service/ArticleService.java:8
↓ 1 callersMethodgetCanalConnector
()
data-dump/src/main/java/com/es/datadump/manager/canal/CanalInitClientManager.java:24
↓ 1 callersMethodgetClientFromPool
从线程池中获取ES客户端 @return
stone/src/main/java/com/es/stone/manager/ElasticSearchInitClientManager.java:96
↓ 1 callersMethodgetDateMap
区分索引进行业务关联同步 @param colMap @param index @return
data-dump/src/main/java/com/es/datadump/manager/ServiceImportManager.java:24
↓ 1 callersMethodgetDateMap
区分索引进行业务关联同步 @param colMap @param index @return @throws Exception
data-migration/src/main/java/com/es/datamigration/manager/ServiceImportManager.java:28
↓ 1 callersMethodgetDestination
()
data-dump/src/main/java/com/es/datadump/manager/canal/CanalInitClientManager.java:55
↓ 1 callersMethodgetErrorCode
()
stone/src/main/java/com/es/stone/result/ResultSupport.java:42
↓ 1 callersMethodgetErrorMsg
()
stone/src/main/java/com/es/stone/result/ResultSupport.java:34
↓ 1 callersMethodgetIndexStrByIndexType
(String indexType)
data-back/src/main/java/com/es/databack/enums/IndexTypeEnum.java:30
↓ 1 callersMethodgetIndexTypeList
()
data-back/src/main/java/com/es/databack/enums/IndexTypeEnum.java:39
↓ 1 callersMethodgetJavaTypeBySqlType
(String sqlType)
data-back/src/main/java/com/es/databack/enums/SqlTypeEnum.java:34
↓ 1 callersMethodgetNameUpper
()
data-back/src/main/java/com/es/databack/common/Table.java:16
↓ 1 callersMethodgetSqlTypeByIndexType
(String indexType)
data-back/src/main/java/com/es/databack/enums/IndexTypeEnum.java:21
↓ 1 callersMethodgetType
()
stone/src/main/java/com/es/stone/enums/EsStatus.java:20
↓ 1 callersMethodinsertOrUpdateToEsWithType
同步插入或更新ES数据方法 @param colMap @param index
stone/src/main/java/com/es/stone/manager/ElasticSearchDumpManager.java:71
↓ 1 callersMethodloadByte
加载class文件,转换为字节数组
stone/src/main/java/com/es/stone/util/CustomizationClassLoader.java:34
↓ 1 callersMethodlocationConverter
(Map colMap)
stone/src/main/java/com/es/stone/converter/LocationConverter.java:15
↓ 1 callersMethodmakeFile
生成文件 @param fileName @throws IOException
data-back/src/main/java/com/es/databack/util/FileHelper.java:44
↓ 1 callersMethodparseTable
解析数据表 @param tableName @return @throws Exception
data-back/src/main/java/com/es/databack/controller/CreateController.java:160
↓ 1 callersMethodprintSummary
(Message message, long batchId, int size)
data-dump/src/main/java/com/es/datadump/manager/canal/AbstractCanalCoreManager.java:144
↓ 1 callersMethodqueryArticleList
article列表信息列表查询 @param queryArticleSearchVO @return
data-search/src/main/java/com/es/datasearch/manager/tbArticle/ArticleSearchManager.java:53
↓ 1 callersMethodreplaceLine
删除字符串中 横线 @param param @return
data-back/src/main/java/com/es/databack/util/StringUtil.java:59
↓ 1 callersMethodrun
(String... args)
data-migration/src/main/java/com/es/datamigration/run/ElasticSearchInitRunner.java:24
↓ 1 callersMethodselectByPage
分页查询所有数据列表 @return
data-migration/src/main/java/com/es/datamigration/mapper/TbArticleDOMapper.java:20
↓ 1 callersMethodsetCanalConnector
(CanalConnector canalConnector)
data-dump/src/main/java/com/es/datadump/manager/canal/AbstractCanalCoreManager.java:409
↓ 1 callersMethodsetElasticSearchDumpManager
(ElasticSearchDumpManager elasticSearchDumpManager)
data-dump/src/main/java/com/es/datadump/manager/canal/AbstractCanalCoreManager.java:413
↓ 1 callersMethodsetServiceImportManager
(ServiceImportManager serviceImportManager)
data-dump/src/main/java/com/es/datadump/manager/canal/AbstractCanalCoreManager.java:417
↓ 1 callersMethodsetSuccess
(boolean success)
stone/src/main/java/com/es/stone/result/ResultSupport.java:30
↓ 1 callersMethodsetValue
(T value)
stone/src/main/java/com/es/stone/result/BaseResult.java:16
↓ 1 callersMethodstart
()
data-dump/src/main/java/com/es/datadump/manager/canal/AbstractCanalCoreManager.java:81
↓ 1 callersMethodstop
()
data-dump/src/main/java/com/es/datadump/manager/canal/AbstractCanalCoreManager.java:95
↓ 1 callersMethodstringToAddress
将ip:port格式装换为 InetSocketAddress对象返回 @param server @return
data-dump/src/main/java/com/es/datadump/manager/canal/CanalInitClientManager.java:47
↓ 1 callersMethodsyncDataControl
同步数据到ES主控方法
data-migration/src/main/java/com/es/datamigration/manager/article/ArticleSyncToEsManager.java:32
↓ 1 callersMethodsyncEntry
数据同步顶层方法,加入事物判断。 @param entries @throws Exception
data-dump/src/main/java/com/es/datadump/manager/canal/AbstractCanalCoreManager.java:176
↓ 1 callersMethodtxListInfoDump
根据特殊业务表同步数据 @param colMap @param index
data-dump/src/main/java/com/es/datadump/manager/ServiceImportManager.java:41
↓ 1 callersMethodtxListInfoDump
根据特殊业务表同步数据 @param colMap @param index
data-migration/src/main/java/com/es/datamigration/manager/ServiceImportManager.java:47
MethodAbstractCanalCoreManager
(String destination)
data-dump/src/main/java/com/es/datadump/manager/canal/AbstractCanalCoreManager.java:72
MethodBaseErrorCode
(int errorCode, String errorMsg)
stone/src/main/java/com/es/stone/result/BaseErrorCode.java:12
MethodBaseResult
(T value)
stone/src/main/java/com/es/stone/result/BaseResult.java:20
MethodCanalCoreManager
(String destination)
data-dump/src/main/java/com/es/datadump/manager/canal/CanalCoreManager.java:5
MethodEsStatus
(String desc,int type)
stone/src/main/java/com/es/stone/enums/EsStatus.java:11
MethodIdConverter
(Map colMap, String index)
stone/src/main/java/com/es/stone/converter/IdConverter.java:14
MethodIndexTypeEnum
(String indexType, String sqlType, String indexStr)
data-back/src/main/java/com/es/databack/enums/IndexTypeEnum.java:15
MethodMobilePager
(int pageSize, Integer totalCount)
stone/src/main/java/com/es/stone/util/MobilePager.java:16
MethodPager
()
stone/src/main/java/com/es/stone/util/Pager.java:17
MethodPagers
()
stone/src/main/java/com/es/stone/util/Pagers.java:11
MethodResultSupport
()
stone/src/main/java/com/es/stone/result/ResultSupport.java:16
MethodSqlTypeEnum
(String sqlType, String javaType)
data-back/src/main/java/com/es/databack/enums/SqlTypeEnum.java:29
MethodSyncDataThread
(int id, List<Entry> entryList)
data-dump/src/main/java/com/es/datadump/manager/canal/AbstractCanalCoreManager.java:281
MethodSyncRowDataThread
(int id, List<RowData> rowDataList, Entry entry, EventType eventType)
data-dump/src/main/java/com/es/datadump/manager/canal/AbstractCanalCoreManager.java:386
MethodWebPager
(int pageSize, int currentPage)
stone/src/main/java/com/es/stone/util/WebPager.java:11
Methodcall
()
data-dump/src/main/java/com/es/datadump/manager/canal/AbstractCanalCoreManager.java:393
MethodcamelToUnderline
驼峰格式字符串转换为下划线格式字符串 @param param @return
data-back/src/main/java/com/es/databack/util/StringUtil.java:13
MethodcheckDatabase
检查数据库相关配置 @return
data-back/src/main/java/com/es/databack/controller/CheckController.java:69
MethodcheckIndex
检查索引情况并根据情况创建索引 @param index @return
stone/src/main/java/com/es/stone/manager/ElasticSearchIndexManager.java:44
Methodcompare
(String obj1, String obj2)
data-dump/src/main/java/com/es/datadump/manager/canal/AbstractCanalCoreManager.java:212
MethodcompilerJava
编译java文件
stone/src/main/java/com/es/stone/util/Test.java:14
MethodcontextLoads
()
stone/src/test/java/com/es/stone/StoneApplicationTests.java:12
MethodcontextLoads
()
data-search/src/test/java/com/es/datasearch/DataSearchApplicationTests.java:12
next →1–100 of 176, ranked by callers