Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/HappyWjl/es-home
/ functions
Functions
176 in github.com/HappyWjl/es-home
⨍
Functions
176
◇
Types & classes
71
↓ 20 callers
Method
buildSuccessResult
(U value)
stone/src/main/java/com/es/stone/result/BaseResult.java:28
↓ 15 callers
Method
getValue
()
stone/src/main/java/com/es/stone/result/BaseResult.java:12
↓ 6 callers
Method
getElasticClient
()
stone/src/main/java/com/es/stone/manager/ElasticSearchInitClientManager.java:27
↓ 6 callers
Method
toCamelCase
驼峰转下划线 @param str @return
stone/src/main/java/com/es/stone/util/CamelCaseUtils.java:42
↓ 5 callers
Method
insertOrUpdateToEs
同步插入或更新ES数据方法 @param colMap @param index
stone/src/main/java/com/es/stone/manager/ElasticSearchDumpManager.java:61
↓ 5 callers
Method
toUnderlineName
下划线转驼峰 @param str @return
stone/src/main/java/com/es/stone/util/CamelCaseUtils.java:10
↓ 4 callers
Method
getConnection
获取数据库链接 @param driver @param url @param name @param pwd @return
data-back/src/main/java/com/es/databack/util/DatabaseUtil.java:17
↓ 3 callers
Method
index
获取索引类型列表 @return
data-back/src/main/java/com/es/databack/controller/ConstantController.java:88
↓ 3 callers
Method
run
(String... args)
data-dump/src/main/java/com/es/datadump/run/CanalClientRunner.java:33
↓ 2 callers
Method
apiInfo
()
data-back/src/main/java/com/es/databack/configuration/Swagger2Config.java:29
↓ 2 callers
Method
apiInfo
()
data-migration/src/main/java/com/es/datamigration/configuration/Swagger2Config.java:29
↓ 2 callers
Method
buildPositionForDump
(Entry entry)
data-dump/src/main/java/com/es/datadump/manager/canal/AbstractCanalCoreManager.java:162
↓ 2 callers
Method
checkIndex
检查索引相关配置 @return
data-back/src/main/java/com/es/databack/controller/CheckController.java:42
↓ 2 callers
Method
convertDate
(Map mapDTO)
data-search/src/main/java/com/es/datasearch/util/ConvertDateUtil.java:23
↓ 2 callers
Method
genFileDir
转换java文件头部文案 @param dir @param params @return
data-back/src/main/java/com/es/databack/util/FileHelper.java:59
↓ 2 callers
Method
getDesc
()
stone/src/main/java/com/es/stone/enums/EsStatus.java:16
↓ 2 callers
Method
initClientPool
初始化ES连接池 连接池有上限,若连接池满,则阻塞等待占用的线程释放ES客户端连接。 一旦连接被释放,池中存在空闲客户端,即可继续被消费。
stone/src/main/java/com/es/stone/manager/ElasticSearchInitClientManager.java:75
↓ 2 callers
Method
isExistsIndex
判断索引是否存在,通用方法 @param index @return @throws Exception
stone/src/main/java/com/es/stone/manager/ElasticSearchDumpManager.java:149
↓ 2 callers
Method
load
(List<T> data, int totalCount)
stone/src/main/java/com/es/stone/util/WebPager.java:16
↓ 2 callers
Method
process
()
data-dump/src/main/java/com/es/datadump/manager/canal/AbstractCanalCoreManager.java:111
↓ 2 callers
Method
serverToHttpHost
(String servers)
stone/src/main/java/com/es/stone/manager/ElasticSearchInitClientManager.java:41
↓ 1 callers
Method
analysisColumn
解析mysql的binlog方法,返回key列名和值value @param columns @return
data-dump/src/main/java/com/es/datadump/manager/canal/AbstractCanalCoreManager.java:205
↓ 1 callers
Method
articleListInfoDump
根据article表同步数据 @param colMap @param index
data-migration/src/main/java/com/es/datamigration/manager/ServiceImportManager.java:59
↓ 1 callers
Method
buildMobilePager
( List<T> data, Function<T, Long> anchorIdFunc, int pageSize, boolean getAnchorIdByLast)
stone/src/main/java/com/es/stone/util/Pagers.java:23
↓ 1 callers
Method
buildWebPager
( List<T> data, int pageSize, int currentPage, int totalCount)
stone/src/main/java/com/es/stone/util/Pagers.java:14
↓ 1 callers
Method
builderArticleSquareCondition
组装文章查询逻辑 @param queryArticleSearchVO @return
data-search/src/main/java/com/es/datasearch/manager/tbArticle/ArticleSearchManager.java:104
↓ 1 callers
Method
bytesToString
(byte[] input, String sourceCharSet,String destCharSet)
data-dump/src/main/java/com/es/datadump/util/CharSetUtil.java:13
↓ 1 callers
Method
call
()
data-dump/src/main/java/com/es/datadump/manager/canal/AbstractCanalCoreManager.java:286
↓ 1 callers
Method
checkColumn
(String tableName, String[] columns)
data-back/src/main/java/com/es/databack/controller/CheckController.java:187
↓ 1 callers
Method
checkIndexType
(String[] columns, String[] indexTypes)
data-back/src/main/java/com/es/databack/controller/CheckController.java:203
↓ 1 callers
Method
checkTable
(Connection conn, String tableName)
data-back/src/main/java/com/es/databack/controller/CheckController.java:115
↓ 1 callers
Method
convertArray
(String str)
stone/src/main/java/com/es/stone/converter/ArrayConverter.java:5
↓ 1 callers
Method
convertTbArticle
db_search.tb_article创建逻辑 @param index @return
stone/src/main/java/com/es/stone/manager/ElasticSearchIndexManager.java:25
↓ 1 callers
Method
convertToMap
(TbArticleDO tbArticleDO)
data-migration/src/main/java/com/es/datamigration/util/ConvertMapUtil.java:13
↓ 1 callers
Method
createIndex
根据配置创建索引,通用方法 @param createRequest @return @throws Exception
stone/src/main/java/com/es/stone/manager/ElasticSearchDumpManager.java:137
↓ 1 callers
Method
createIndexRequest
配置索引请求规则 @param index @return
data-back/src/main/java/com/es/databack/controller/CreateController.java:113
↓ 1 callers
Method
deleteRecordToEs
同步删除ES数据方法 @param colMap @param index
stone/src/main/java/com/es/stone/manager/ElasticSearchDumpManager.java:45
↓ 1 callers
Method
disConnect
(RestHighLevelClient client)
stone/src/main/java/com/es/stone/manager/ElasticSearchInitClientManager.java:110
↓ 1 callers
Method
esKeyString
排序组装es的id,兼容联合主键 @param keyMap @return
stone/src/main/java/com/es/stone/manager/ElasticSearchDumpManager.java:31
↓ 1 callers
Method
findAllFile
根据路径搜索所有文件 @param file @return
data-back/src/main/java/com/es/databack/util/FileHelper.java:18
↓ 1 callers
Method
gen
<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 callers
Method
getArticleList
(QueryArticleSearchVO queryArticleSearchVO)
data-search/src/main/java/com/es/datasearch/service/ArticleService.java:8
↓ 1 callers
Method
getCanalConnector
()
data-dump/src/main/java/com/es/datadump/manager/canal/CanalInitClientManager.java:24
↓ 1 callers
Method
getClientFromPool
从线程池中获取ES客户端 @return
stone/src/main/java/com/es/stone/manager/ElasticSearchInitClientManager.java:96
↓ 1 callers
Method
getDateMap
区分索引进行业务关联同步 @param colMap @param index @return
data-dump/src/main/java/com/es/datadump/manager/ServiceImportManager.java:24
↓ 1 callers
Method
getDateMap
区分索引进行业务关联同步 @param colMap @param index @return @throws Exception
data-migration/src/main/java/com/es/datamigration/manager/ServiceImportManager.java:28
↓ 1 callers
Method
getDestination
()
data-dump/src/main/java/com/es/datadump/manager/canal/CanalInitClientManager.java:55
↓ 1 callers
Method
getErrorCode
()
stone/src/main/java/com/es/stone/result/ResultSupport.java:42
↓ 1 callers
Method
getErrorMsg
()
stone/src/main/java/com/es/stone/result/ResultSupport.java:34
↓ 1 callers
Method
getIndexStrByIndexType
(String indexType)
data-back/src/main/java/com/es/databack/enums/IndexTypeEnum.java:30
↓ 1 callers
Method
getIndexTypeList
()
data-back/src/main/java/com/es/databack/enums/IndexTypeEnum.java:39
↓ 1 callers
Method
getJavaTypeBySqlType
(String sqlType)
data-back/src/main/java/com/es/databack/enums/SqlTypeEnum.java:34
↓ 1 callers
Method
getNameUpper
()
data-back/src/main/java/com/es/databack/common/Table.java:16
↓ 1 callers
Method
getSqlTypeByIndexType
(String indexType)
data-back/src/main/java/com/es/databack/enums/IndexTypeEnum.java:21
↓ 1 callers
Method
getType
()
stone/src/main/java/com/es/stone/enums/EsStatus.java:20
↓ 1 callers
Method
insertOrUpdateToEsWithType
同步插入或更新ES数据方法 @param colMap @param index
stone/src/main/java/com/es/stone/manager/ElasticSearchDumpManager.java:71
↓ 1 callers
Method
loadByte
加载class文件,转换为字节数组
stone/src/main/java/com/es/stone/util/CustomizationClassLoader.java:34
↓ 1 callers
Method
locationConverter
(Map colMap)
stone/src/main/java/com/es/stone/converter/LocationConverter.java:15
↓ 1 callers
Method
makeFile
生成文件 @param fileName @throws IOException
data-back/src/main/java/com/es/databack/util/FileHelper.java:44
↓ 1 callers
Method
parseTable
解析数据表 @param tableName @return @throws Exception
data-back/src/main/java/com/es/databack/controller/CreateController.java:160
↓ 1 callers
Method
printSummary
(Message message, long batchId, int size)
data-dump/src/main/java/com/es/datadump/manager/canal/AbstractCanalCoreManager.java:144
↓ 1 callers
Method
queryArticleList
article列表信息列表查询 @param queryArticleSearchVO @return
data-search/src/main/java/com/es/datasearch/manager/tbArticle/ArticleSearchManager.java:53
↓ 1 callers
Method
replaceLine
删除字符串中 横线 @param param @return
data-back/src/main/java/com/es/databack/util/StringUtil.java:59
↓ 1 callers
Method
run
(String... args)
data-migration/src/main/java/com/es/datamigration/run/ElasticSearchInitRunner.java:24
↓ 1 callers
Method
selectByPage
分页查询所有数据列表 @return
data-migration/src/main/java/com/es/datamigration/mapper/TbArticleDOMapper.java:20
↓ 1 callers
Method
setCanalConnector
(CanalConnector canalConnector)
data-dump/src/main/java/com/es/datadump/manager/canal/AbstractCanalCoreManager.java:409
↓ 1 callers
Method
setElasticSearchDumpManager
(ElasticSearchDumpManager elasticSearchDumpManager)
data-dump/src/main/java/com/es/datadump/manager/canal/AbstractCanalCoreManager.java:413
↓ 1 callers
Method
setServiceImportManager
(ServiceImportManager serviceImportManager)
data-dump/src/main/java/com/es/datadump/manager/canal/AbstractCanalCoreManager.java:417
↓ 1 callers
Method
setSuccess
(boolean success)
stone/src/main/java/com/es/stone/result/ResultSupport.java:30
↓ 1 callers
Method
setValue
(T value)
stone/src/main/java/com/es/stone/result/BaseResult.java:16
↓ 1 callers
Method
start
()
data-dump/src/main/java/com/es/datadump/manager/canal/AbstractCanalCoreManager.java:81
↓ 1 callers
Method
stop
()
data-dump/src/main/java/com/es/datadump/manager/canal/AbstractCanalCoreManager.java:95
↓ 1 callers
Method
stringToAddress
将ip:port格式装换为 InetSocketAddress对象返回 @param server @return
data-dump/src/main/java/com/es/datadump/manager/canal/CanalInitClientManager.java:47
↓ 1 callers
Method
syncDataControl
同步数据到ES主控方法
data-migration/src/main/java/com/es/datamigration/manager/article/ArticleSyncToEsManager.java:32
↓ 1 callers
Method
syncEntry
数据同步顶层方法,加入事物判断。 @param entries @throws Exception
data-dump/src/main/java/com/es/datadump/manager/canal/AbstractCanalCoreManager.java:176
↓ 1 callers
Method
txListInfoDump
根据特殊业务表同步数据 @param colMap @param index
data-dump/src/main/java/com/es/datadump/manager/ServiceImportManager.java:41
↓ 1 callers
Method
txListInfoDump
根据特殊业务表同步数据 @param colMap @param index
data-migration/src/main/java/com/es/datamigration/manager/ServiceImportManager.java:47
Method
AbstractCanalCoreManager
(String destination)
data-dump/src/main/java/com/es/datadump/manager/canal/AbstractCanalCoreManager.java:72
Method
BaseErrorCode
(int errorCode, String errorMsg)
stone/src/main/java/com/es/stone/result/BaseErrorCode.java:12
Method
BaseResult
(T value)
stone/src/main/java/com/es/stone/result/BaseResult.java:20
Method
CanalCoreManager
(String destination)
data-dump/src/main/java/com/es/datadump/manager/canal/CanalCoreManager.java:5
Method
EsStatus
(String desc,int type)
stone/src/main/java/com/es/stone/enums/EsStatus.java:11
Method
IdConverter
(Map colMap, String index)
stone/src/main/java/com/es/stone/converter/IdConverter.java:14
Method
IndexTypeEnum
(String indexType, String sqlType, String indexStr)
data-back/src/main/java/com/es/databack/enums/IndexTypeEnum.java:15
Method
MobilePager
(int pageSize, Integer totalCount)
stone/src/main/java/com/es/stone/util/MobilePager.java:16
Method
Pager
()
stone/src/main/java/com/es/stone/util/Pager.java:17
Method
Pagers
()
stone/src/main/java/com/es/stone/util/Pagers.java:11
Method
ResultSupport
()
stone/src/main/java/com/es/stone/result/ResultSupport.java:16
Method
SqlTypeEnum
(String sqlType, String javaType)
data-back/src/main/java/com/es/databack/enums/SqlTypeEnum.java:29
Method
SyncDataThread
(int id, List<Entry> entryList)
data-dump/src/main/java/com/es/datadump/manager/canal/AbstractCanalCoreManager.java:281
Method
SyncRowDataThread
(int id, List<RowData> rowDataList, Entry entry, EventType eventType)
data-dump/src/main/java/com/es/datadump/manager/canal/AbstractCanalCoreManager.java:386
Method
WebPager
(int pageSize, int currentPage)
stone/src/main/java/com/es/stone/util/WebPager.java:11
Method
call
()
data-dump/src/main/java/com/es/datadump/manager/canal/AbstractCanalCoreManager.java:393
Method
camelToUnderline
驼峰格式字符串转换为下划线格式字符串 @param param @return
data-back/src/main/java/com/es/databack/util/StringUtil.java:13
Method
checkDatabase
检查数据库相关配置 @return
data-back/src/main/java/com/es/databack/controller/CheckController.java:69
Method
checkIndex
检查索引情况并根据情况创建索引 @param index @return
stone/src/main/java/com/es/stone/manager/ElasticSearchIndexManager.java:44
Method
compare
(String obj1, String obj2)
data-dump/src/main/java/com/es/datadump/manager/canal/AbstractCanalCoreManager.java:212
Method
compilerJava
编译java文件
stone/src/main/java/com/es/stone/util/Test.java:14
Method
contextLoads
()
stone/src/test/java/com/es/stone/StoneApplicationTests.java:12
Method
contextLoads
()
data-search/src/test/java/com/es/datasearch/DataSearchApplicationTests.java:12
next →
1–100 of 176, ranked by callers