Skip to content

基于flink1.12,使用java,flink sql的demo,包含Mylsql, flinkcdc内置的Mysqlcdc

License

Notifications You must be signed in to change notification settings

bingoguo93/flink-1.12-sql-demo

Repository files navigation

License

flink1.12.1 sql demo

个人练习flink 的demo。

代码里自带数据生成,配有合适的数据演示。

pom.xml包含了flink绝大部分的依赖,maven下载会比较久。

目前项目内容包含了flink streamset flinkSQL flinkCDC Mysql

环境

Windows 10 ltsc

Mysql8.0.23

Idea社区版2020.3

HaidiSQL

环境搭建教程:https://www.cnblogs.com/abramgyb/p/14587901.html

streamset

使用streamset api编写flink程序

flink sql

flink sql api编写程序,实现ETL功能,包含读写Mysql,kafka

source Mysql MysqlCDC

sink Mysql

使用说明

环境搭建教程:https://www.cnblogs.com/abramgyb/p/14587901.html

依赖下载完成后运行demo测试

About

基于flink1.12,使用java,flink sql的demo,包含Mylsql, flinkcdc内置的Mysqlcdc

Topics

Resources

License

Stars

Watchers

Forks

Packages

No packages published

Languages