flink1.12.x window api使用-处理时间的滚动窗口(TumblingProcessingTimeWindows)
flink1.12.x Table API 和 SQL:Row、RowTypeInfo、TypeInformation、BasicTypeInfo
flink1.12.x Table API 和 SQL:Connector 连接器从kafka读取数据
flink1.12.x Table API 和 SQL:UDF用户自定义函数-AggregateFunction聚合函数
flink1.12.x Table API 和 SQL:UDF用户自定义函数-ScalarFunction标量函数
flink1.12.x Table API 和 SQL:更新模式:追加Append、撤回Retract、更新插入Upsert
flink1.12.x Table API 和 SQL:sink将查询结果写入到elasticsearch(聚合查询)
flink1.12.x Table API 和 SQL:Connector 连接器
flink1.12.x SQL:滚动窗口-显示窗口时间函数:TUMBLE_START、TUMBLE_END、TUMBLE_ROWTIME、TUMBLE_PROCTIME
flink1.12.x State状态数据类型:ValueState、ListState、ReducingState、AggregatingState、MapState