2.3.1 Keyed Window /Non-Keyed Window

stream
.keyBy(...).window(...) / 或者windowAll(...)//需要windowAssigner(窗口分配器)参数，滚动窗口、滑动窗口、会话窗口
//Trigger类型(触发器)参数，Trigger用来判断执行时机。Trigger类中定义返回值类型，根据返回值类型来决定是否触发及触发什么动作。
[.trigger()]
//Evictor(驱逐器)。在窗口触发之后，在调用窗口函数之前或之后，Flink允许定制要处理的数据集合。Evictor用来驱逐或者过滤不需要的数据集。
[.evictor()]
//最大允许延迟。用于基于事件时间的窗口，在水位线到达之后的最长允许数据延迟时间。在最长允许延迟时间内，窗口不会销毁。
[.allowedLateness()]
//用来定义抛弃数据的输出
[.sideOutputLateData()]
[.reduce/aggregate/fold/apply()]
//获取丢弃数据的DataStream
[.getSideOutput()]

2.3.2 窗口的执行流程

//TODO 执行过程