© 1999-2048 dssz.net 粤ICP备11031372号
[其它] FlinkSQL:仿照阿里blink使用sql开发flink的实时程序-源码
说明:一。背景 阿里工作的时候是使用Blink进行流数据处理和计算,通过编写sql实现Blink的计算作业,开发简单高效,产品易用。目前尝试实现Flink产品化,类似的Blink。使用SQL为统一开发规范,SQL语言如果采用API开发的话,最大的问题是对于作业调优依赖程序员经验,比较困难,同时API开发方式侵入性太强(数据安全,具备安全性等),而sql可以自动调优,避免这种问题的产生。 二。实现思路: 用户输入sql(ddl,query,dml) -> ddl对应为Flink的source和s<weixin_42164685> 上传 | 大小:153kb