flink1.12.x Table API 和 SQL:从kafka读取数据,写入到elasticsearch,上传flink集群,flink run执行jar(独立集群模式)
kafka_2.12-2.4.x集群-编写集群启动脚本、停止脚本
flink1.12.x Table API 和 SQL:sink将查询结果写入到elasticsearch(聚合查询)
future versions of Elasticsearch will require Java 11; your Java version from does not meet this requirement
elasticsearch7.9.x linux 安装部署、启动
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:更新模式:追加Append、撤回Retract、更新插入Upsert