flink1.12.x Table API 和 SQL:从kafka读取数据,写入到elasticsearch,上传flink集群,flink run执行jar(独立集群模式)
kafka_2.12-2.4.x集群-编写集群启动脚本、停止脚本
flink1.12.x Table API 和 SQL:从kafka读取数据,聚合查询,写入到elasticsearch
flink1.12.x Table API 和 SQL:sink将查询结果写入到elasticsearch(聚合查询)
flink1.12.x 设置job名称
flink1.12.x Table API 和 SQL:kafka读写数据,上传到flink集群,flink run执行jar(独立集群模式)
flink1.12.x Table API 和 SQL:从kafka读取数据,执行查询,将结果写入到kafka中
flink1.12.x Table API 和 SQL:读取HDFS文件,将结果写入到HDFS,上传到flink集群,flink run执行jar(独立集群模式)
flink1.12.x Table API 和 SQL:Table 转换成 DataStream
flink1.12.x Table API 和 SQL:sink将查询结果写入到文件(非聚合查询)