文件名称:flink-1.12-sql-demo:基于flink1.12,使用java,flink sql的demo,包含Mylsql,flinkcdc内置的Mysqlcdc
文件大小:79KB
文件格式:ZIP
更新时间:2024-04-17 04:44:24
flink flinksql flinkcdc mysqlcdc Java
flink1.12.1 sql演示 个人练习flink的演示。 代码里自带数据生成,附带合适的数据演示。 pom.xml包含了flink绝大部分的依赖,maven下载会比较久。 目前项目内容包含了 环境 Windows 10 ltsc 的Mysql8.0.23 Idea社区版2020.3 海地SQL 环境建设教程: ://www.cnblogs.com/abramgyb/p/14587901.html 流集 使用streamset api编写flink程序 FlinkSQL flink sql api编程程序,实现ETL功能,包含读写Mysql,kafka 源Mysql MysqlCDC 下沉Mysql 使用说明 克隆仓库:git clone 使用idea打开项目 maven下载相关依赖 依赖下载完成后运行demo测试
【文件预览】:
flink-1.12-sql-demo-main
----.gitattributes(66B)
----src()
--------main()
----flinksql_demo.iml(80B)
----target()
--------classes()
----.idea()
--------misc.xml(513B)
--------compiler.xml(597B)
--------uiDesigner.xml(9KB)
--------encodings.xml(261B)
--------.gitignore(47B)
--------jarRepositories.xml(2KB)
--------vcs.xml(180B)
----LICENSE(11KB)
----README.md(999B)
----pom.xml(12KB)