flink1.12.x Table API 和 SQL：UDF用户自定义函数-AggregateFunction聚合函数

flink1.12.x Table API 和 SQL：UDF用户自定义函数-ScalarFunction标量函数

flink1.12.x Table API 和 SQL：开发流程-动态表 和 持续查询

flink1.12.x Table API 和 SQL：开发流程-查询结果表转换成流

flink1.12.x Table API 和 SQL：读取csv文件，实现分组聚合查询

pytorch api文档：torch.load()函数-加载整个模型、模型状态字典（可训练参数）

pytorch api文档：torch.save()函数-保存整个模型、模型状态字典（可训练参数）

pytorch api文档：nn.Module类的.train()方法-将模型切换为训练模式

flink1.12.x window窗口api使用说明：WindowAssigner、function、triger、evictor、allowedLateness、sideOutputLateData、getSideOutput

flink1.12.x Table API 和 SQL：从kafka读取数据，聚合查询，写入到elasticsearch