syncer：将数据从MySQLMongoDB同步并处理到ElasticsearchMySQLHttpKafka端点
需积分: 19 22 浏览量
2021-02-04
06:03:33
上传
评论
收藏 351KB ZIP 举报
syncer：将数据从MySQLMongoDB同步并处理到ElasticsearchMySQLHttpKafka端点 （360个子文件） 
my.cnf 32B Dockerfile 291B DataGenerator.Dockerfile 143B .gitignore 334B ESRequestMapperTest.java 28KB ElasticsearchChannel.java 17KB ESScriptUpdate.java 14KB ConsumerSchemaMeta.java 13KB SyncData.java 11KB DataGenerator.java 11KB CompareDetail.java 10KB MongoGenerator.java 9KB MysqlChannel.java 9KB MongoV4MasterConnector.java 8KB MysqlMasterConnector.java 8KB ESRequestMapper.java 7KB JsonSyncResultTest.java 7KB FileBasedMapTest.java 7KB MongoMasterConnector.java 6KB ConsumerStarter.java 6KB SyncDataTest.java 6KB ElasticsearchJavaAPIScriptTest.java 6KB KafkaChannel.java 6KB MasterSource.java 6KB RedisChannel.java 5KB ProducerStarter.java 5KB YamlEnvironmentPostProcessor.java 5KB FilterJob.java 5KB SpringELTest.java 5KB Ack.java 5KB NettyClientTest.java 5KB SyncListener.java 5KB Connection.java 5KB SyncData.java 4KB SQLMapper.java 4KB MongoConnectorBase.java 4KB BatchBuffer.java 4KB ClusterConnection.java 4KB ConsumerChannel.java 4KB ESQueryMapper.java 4KB LocalConsumerSource.java 4KB MysqlDispatcher.java 4KB LocalConsumerRegistry.java 4KB SyncerApplication.java 4KB JavaMethod.java 4KB FilterConfig.java 4KB JsonSyncResult.java 4KB MysqlChannelTest.java 3KB SQLHelper.java 3KB SyncUtilTest.java 3KB Repo.java 3KB NestedSQLMapper.java 3KB HttpChannel.java 3KB FailureLog.java 3KB SyncDataTypeUtil.java 3KB Redis.java 3KB BinlogInfo.java 3KB BinlogDataId.java 3KB MayClusterConnection.java 3KB Kafka.java 3KB SyncUtil.java 3KB MongoV4MasterConnectorTest.java 3KB ExportServer.java 3KB ElasticsearchConnection.java 3KB FileBasedMap.java 3KB RowsEvent.java 3KB ESScriptUpdate.java 3KB OutputStarter.java 3KB CopyOnWriteListTest.java 3KB SyncerHealth.java 3KB DataId.java 3KB LocalMetaFile.java 2KB PipelineOutput.java 2KB ExtraQuery.java 2KB SQLMapperTest.java 2KB EtcdBasedFile.java 2KB Consumer.java 2KB MongoTypeUtil.java 2KB FileUtil.java 2KB Switch.java 2KB KVMapper.java 2KB TableMeta.java 2KB LocalMetaFileTest.java 2KB DispatchHandler.java 2KB SchemaMeta.java 2KB SQLHelperTest.java 2KB MongoDispatcher.java 2KB OperationMapper.java 2KB ForeachFilter.java 2KB LocalAndEtcdMetaFile.java 2KB MysqlConnection.java 2KB ESRequestMapping.java 2KB Elasticsearch.java 2KB Http.java 2KB ConsumerInitContext.java 2KB Statement.java 2KB PipelineBatchConfig.java 2KB SyncDeserializer.java 2KB IfConfig.java 2KB SyncDataTestUtil.java 2KB共 360 条
- 1
- 2
- 3
- 4
资源评论
