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
flink1.12.x Table API 和 SQL:读取csv文件,实现分组聚合查询
flink1.12.x Table API 和 SQL:创建工程,读取csv文件,创建表,实现查询(connector连接器)