-
flinkStreamSQL下载
资源介绍
flinkStreamSQL
基于开源的flink，对其实时sql进行扩展
自定义create table 语法（包括源表,输出表,维表）
自定义create view 语法
自定义create function 语法
实现了流与维表的join
支持原生FLinkSQL所有的语法
扩展了输入和输出的性能指标到promethus
新特性:
1.kafka源表支持not null语法,支持字符串类型的时间转换。
2.rdb维表与DB建立连接时，周期进行连接，防止连接断开。rdbsink写入时，对连接进行检查。
3.异步维表支持非等值连接，比如：<>,<,>。
4.增加kafka数组解析
5.增加kafka1.0以上版本的支持
6.增加postgresql、kudu、clickhouse维表、结果表的支持
7.支持插件的依赖方式,参考pluginLoadMode参数
8.支持cep处理
9.支持