Flink学习笔记（七）：数据转换过程与可选api

Flink的数据转换过程，一般是从最开始创建一个DataStream经过一系列转换，最终又回到DataStream，如下图所示：

其中windowedStream的可选api有：

• trigger() 触发器：定义window什么时候关闭，触发计算并输出结果，例如滚动时间窗口有一个默认触发器，它的触发条件是时间达到endTime
• evitor() 移除器：定义移除某些数据的逻辑
• allowedLateness() 运行处理迟到的数据
• sideOutputLateData() 将迟到的数据放入侧输出流（一个特殊的流）
• getSideOutput() 获取侧输出流