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