【文件属性】：
文件名称：FlinkSQL:仿照阿里blink使用sql开发flink的实时程序
文件大小：153KB
文件格式：ZIP
更新时间：2021-03-21 11:18:28
Java
一。背景
阿里工作的时候是使用Blink进行流数据处理和计算，通过编写sql实现Blink的计算作业，开发简单高效，产品易用。目前尝试实现Flink产品化，类似的Blink。使用SQL为统一开发规范，SQL语言如果采用API开发的话，最大的问题是对于作业调优依赖程序员经验，比较困难，同时API开发方式侵入性太强（数据安全，具备安全性等），而sql可以自动调优，避免这种问题的产生。
二。实现思路：
用户输入sql（ddl,query,dml） -> ddl对应为Flink的source和sink
-> query/dml的insert into数据处理和计算
【文件预览】：
FlinkSQL-master
----.gitignore(13B)
----blink-client()
--------src()
--------pom.xml(2KB)
----blink-libraries()
--------pom.xml(1KB)
--------mysql()
----blink-sql()
--------src()
--------pom.xml(2KB)
----blink-stream()
--------src()
--------pom.xml(3KB)
----blink-job()
--------src()
--------pom.xml(2KB)
----LICENSE(11KB)
----doc()
--------v3.0.0.md(345B)
--------v2.0.1.md(340B)
--------v2.0.0.md(444B)
--------v1.0.0.md(695B)
----pom.xml(11KB)
----README.md(8KB)
----blink-common()
--------src()
--------pom.xml(1KB)