文件名称：sqlSubmit:基于 Flink 的 sqlSubmit 程序
文件大小：148KB
文件格式：ZIP
更新时间：2024-05-04 15:02:10
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)