flink1.12.x Table API 和 SQL:从kafka读取数据,写入到elasticsearch,上传flink集群,flink run执行jar(独立集群模式)
Flink CDC2.0 连接MySQL,将表所有数据打印到控制台
Flink CDC2.0 连接MySQL,增删改数据,查看打印数据格式
flink1.12.x Table API 和 SQL:读取HDFS文件,将结果写入到HDFS,上传到flink集群,flink run执行jar(独立集群模式)
Flink CDC2.0 数据格式和op事件分类(c、u、d、r)
flink 使用 ParameterTool 读取外部配置文件,在算子中访问配置(全局变量)
flink 维表关联、翻译字典-热存储维表-使用AsyncDataStream、RichAsyncFunction 查询Hbase
flink 维表关联、翻译字典-热存储维表-使用asynchbase异步客户端库
flink 维表关联、翻译字典-热存储维表-使用AsyncDataStream、RichAsyncFunction 进行异步处理(查询MySQL)
flink1.12.x Table API 和 SQL:kafka读写数据,打包、上传到flink集群、yarn方式执行