【文件属性】：
文件名称：sqlSubmit:基于 Flink 的 sqlSubmit 程序
文件大小：148KB
文件格式：ZIP
更新时间：2021-04-14 21:15:30
Java
sqlSubmit
基于flinkSQL提交程序
现在只支持flink 1.12.0
了解有关Flink的更多信息
源自Jark的博客
特征
提交flink sql到集群
例子
SQL文件demo.sql像这样：
-- source
CREATE TABLE user_log (
user_id VARCHAR
,item_id VARCHAR
,category_id VARCHAR
,behavior VARCHAR
,ts TIMESTAMP
) WITH (
' connector.type ' = ' kafka ' , -- 使用 kafka connector
, ' connector.version ' = ' universal ' ,
【文件预览】：
sqlSubmit-master
----.gitignore(49B)
----src()
--------main()
--------test()
----git.sh(163B)
----LICENSE(11KB)
----doc()
--------picture()
--------shell()
----pom.xml(9KB)
----README.md(3KB)