flink1.12.x Table API 和 SQL：sink将查询结果写入到elasticsearch（聚合查询）
clickhourse21.7.11.3 SQL语法优化-删除重复的order by key、limit by key
spark3.0教程-SparkSQL：默认shuffle 有200个分区，设置分区数（spark.sql.shuffle.partitions）
flink1.12.x Table API 和 SQL：sink将查询结果写入到文件（非聚合查询）
hive 设置内存
flink1.12.x Table API 和 SQL：从kafka读取数据，执行查询，将结果写入到kafka中
flink1.12.x SQL：滚动窗口-显示窗口时间函数：TUMBLE_START、TUMBLE_END、TUMBLE_ROWTIME、TUMBLE_PROCTIME
flink1.12.x Table API 和 SQL：创建工程，读取csv文件，创建表，实现查询（connector连接器）
flink1.12.x Table API 和 SQL：kafka读写数据，打包、上传到flink集群、yarn方式执行
spark3.0-python教程-SparkSQL：默认shuffle 有200个分区，设置分区数（spark.sql.shuffle.partitions）