# streamx
基于spark的分布式实时数据同步工具
基于spark的分布式实时数据同步工具+源代码+文档说明
版权申诉
52 浏览量
2024-03-20
15:30:04
上传
评论
收藏 339KB ZIP 举报
基于spark的分布式实时数据同步工具+源代码+文档说明
（122个子文件） 
DSLSQL.g4 4KB .gitignore 360B DSLSQLLexer.interp 14KB DSLSQL.interp 14KB DSLSQLParser.java 83KB DSLSQLLexer.java 15KB DSLSQLBaseListener.java 10KB DSLSQLListener.java 10KB DSLSQLBaseVisitor.java 8KB CamelCaseUtils.java 7KB DSLSQLVisitor.java 6KB CaseChangingCharStream.java 2KB kafka2es.json 1KB nc2es.json 1KB nc2output.json 0B LICENSE 11KB streamx配置详解.md 8KB hive.md 5KB mysql.md 5KB es.md 4KB 容错机制.md 670B README.md 58B
3ab4e1ed.png 111KB 767c8f97.png 24KB 1a9249e9.png 23KB log4j.properties 604B ParserTest.scala 14KB StreamUtils.scala 8KB ExchangeRunner.scala 7KB RedisClient.scala 7KB ScriptSQLExec.scala 6KB CuratorTest.scala 6KB ZkDiscoveryPlugin.scala 6KB FailoverPlugin.scala 6KB ConfigParser.scala 5KB SchemaFileReader.scala 5KB MysqlWriter.scala 4KB EsJestClient.scala 4KB KafkaReader.scala 4KB JsonParser.scala 4KB CanalParser.scala 4KB DbUtil.scala 4KB StructuredStreamingTest.scala 4KB ElasticWriter.scala 4KB SchemaJdbcReader.scala 3KB DslAdaptor.scala 3KB HiveWriter.scala 3KB StreamCollectorCore.scala 3KB KafkaOffsetUtils.scala 3KB SchemaHiveReader.scala 3KB FailoverTest.scala 3KB CsvParser.scala 2KB SparkJobTest.scala 2KB PluginManager.scala 2KB BatchStreamingListener.scala 2KB BaseParser.scala 2KB RedisWriter.scala 2KB SocketReader.scala 2KB NewTest.scala 2KB LoadAdaptor.scala 2KB Key.scala 2KB BinlogStream.scala 2KB StreamCollectorConfigStr.scala 2KB SessionConnectionListener.scala 2KB AbstractWriter.scala 2KB ThreadUtils.scala 2KB ExchangeDataConf.scala 2KB MysqlTest.scala 1KB BinlogReader.scala 1KB TransformerConf.scala 1KB StreamCollectorConfigFile.scala 1KB ElasticTest.scala 1KB TestStaff.scala 1KB RedisTest.scala 1KB Parser.scala 1KB BroadcastWrapper.scala 1KB ConfigConf.scala 1KB AbstractReader.scala 1KB StdoutWriter.scala 1023B BroadcastWrapperInstance.scala 1018B StdoutTest.scala 986B ScriptTest1.scala 904B AbstractFailoverPlugin.scala 899B KafkaReaderConf.scala 860B ElasticConf.scala 784B ConfUtil.scala 758B AbstractPlugin.scala 751B RedisConf.scala 731B HiveTest.scala 669B StreamxConf.scala 640B SortConf.scala 615B HiveConf.scala 599B MysqlConf.scala 565B OperationType.scala 498B SaveAdaptor.scala 452B FailoverPluginConf.scala 445B ZkDiscoveryPluginConf.scala 439B ParamsConf.scala 426B SocketReaderConf.scala 422B RowStream.scala 405B共 122 条
- 1
- 2
资源评论
