基于开源的flink对其实时sql进行扩展；主要实现了流与维表的join
需积分: 41 100 浏览量
2019-08-08
10:45:54
上传
评论
收藏 267KB ZIP 举报
基于开源的flink对其实时sql进行扩展；主要实现了流与维表的join （152个子文件） 
.gitignore 125B .gitignore 90B SideSqlExec.java 25KB DateUtil.java 22KB SideSqlExecTest.java 19KB Main.java 15KB FlinkUtil.java 11KB RetractJDBCOutputFormat.java 11KB SideSQLParser.java 9KB ClusterClientFactory.java 9KB SideInfo.java 8KB MysqlAllReqRow.java 8KB HbaseAsyncReqRow.java 8KB MysqlAsyncReqRow.java 8KB HbaseOutputFormat.java 7KB LauncherOptionParser.java 7KB DtStringUtil.java 7KB DtClassLoader.java 6KB DBSink.java 6KB ElasticsearchSink.java 6KB PreRowKeyModeDealerDealer.java 6KB PluginUtil.java 6KB ParserJoinField.java 5KB ClassUtil.java 5KB InsertSqlParser.java 5KB MysqlAsyncSideInfo.java 5KB RowKeyEqualModeDealer.java 5KB TableInfoParserFactory.java 5KB SqlParser.java 5KB ByteUtils.java 5KB JoinInfo.java 4KB HbaseSideParser.java 4KB MyLocalStreamEnvironment.java 4KB AbsTableParser.java 4KB RowKeyBuilder.java 4KB CustomerJsonDeserialization.java 4KB CustomerJsonDeserialization.java 4KB StreamSourceFactory.java 4KB CustomerJsonDeserialization.java 4KB AbsRowKeyModeDealer.java 4KB HbaseSink.java 4KB StreamSinkFactory.java 4KB HbaseSideTableInfo.java 4KB MysqlTableInfo.java 3KB MysqlAllSideInfo.java 3KB KafkaSource.java 3KB KafkaSource.java 3KB KafkaSource.java 3KB CustomerSinkFunc.java 3KB CreateTableParser.java 3KB AsyncReqRow.java 3KB HbaseTableInfo.java 3KB SideAsyncOperator.java 3KB LauncherOptions.java 3KB MysqlSink.java 3KB WaterMarkerAssigner.java 3KB TableInfo.java 3KB KafkaSourceTableInfo.java 3KB KafkaSourceTableInfo.java 3KB KafkaSourceTableInfo.java 3KB SideWithAllCacheOperator.java 3KB LauncherMain.java 3KB JoinScope.java 3KB AbsSideTableParser.java 3KB SourceTableInfo.java 3KB HbaseAsyncSideInfo.java 3KB ElasticsearchTableInfo.java 3KB SideTableInfo.java 3KB CreateFuncParser.java 3KB MathUtil.java 3KB MysqlSideTableInfo.java 3KB MysqlSideParser.java 3KB AbsSourceParser.java 3KB SqlTree.java 2KB HbaseSinkParser.java 2KB MysqlSinkParser.java 2KB ElasticsearchSinkParser.java 2KB ColumnType.java 2KB HbaseUtil.java 2KB AllReqRow.java 2KB StreamSideFactory.java 2KB EsUtil.java 2KB CustomerWaterMarkerForTimeStamp.java 2KB HbaseUtils.java 2KB KafkaSourceParser.java 2KB KafkaSourceParser.java 2KB DTThreadFactory.java 2KB KafkaSourceParser.java 2KB CustomerWaterMarkerForLong.java 2KB LRUSideCache.java 2KB MD5Utils.java 2KB ConfigConstrant.java 2KB TestSideSqlParser.java 2KB FieldReplaceInfo.java 2KB FieldInfo.java 2KB CacheObj.java 2KB ReplaceOperator.java 2KB ReplaceInfo.java 2KB AppTest.java 1KB AppTest.java 1KB共 152 条
- 1
- 2
资源评论
