本项目主要用于个人学习, 扩展flink sql相关功能, 按branch划分flink版本以及功能点, 详情可见对应分支readme文件
-
- flink sql血缘收集(表级别已完成, 列级别未完成)
-
- Flink 自定义动态表(Redis)
- Flink 维表延迟join
- Flink 维表 key by join
- Flink Mini-Batch 维表 Join
- Flink Sql 侧流输出(一)
- Flink Sql 侧流输出(二)
- Flink Sql Increment Window
feature-1.16 分支扩展功能均在 flink 1.12版本上开发