flink-sql-connector-hive-3.1.2_2.11-1.11.6.jar 已经解决guava冲突亲测可以
2022-04-06 02:53:19
40.42MB
1
flink sql学习组件，里面包含flink、flink sql clienk、kafka 、ES、mysql等，使用docker命令加载即可，适用于macos，linux系统学习flink
2022-01-27 09:11:48
2KB
1
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测试
2021-10-12 20:45:24
79KB
1
Kudu连接器
基于Apache-Bahir-Kudu连接器改造而来的满足公司内部使用的Kudu连接器，支持特性范围分区，定义哈希分桶数，支持Flink1.11.x动态数据源等，改造后已贡献部分功能给社区。
使用姿势
clone代码后，改造pom项目坐标后上传公司私服使用
Kudu目录使用
创建目录
StreamExecutionEnvironment env = StreamExecutionEnvironment . getExecutionEnvironment();
catalog = new KuduCatalog ( " cdh01:7051,cdh02:7051,cdh03:7051 " );
tableEnv = KuduTableTestUtils . createTableEnvWithBlinkPlannerStreamingMode(env);
tableEnv .
2021-07-06 11:57:21
162KB
1
kaggle Home_credit 信贷风控 train训练字段的Flink sql 预处理
2021-06-15 13:07:28
12KB
flink-sql-connector-kafka_2.11-1.12.0
2021-03-30 14:21:33
3.48MB
1
flink-sql-connector-kafka_2.11-1.12.2.jar
2021-03-27 19:57:20
3.48MB
1
flink-sql-connector-mysql-cdc-1.1.1.jar
2021-03-12 19:15:24
25.37MB
1