image.png
keyed 相当于把一个slot上运行的一条宽的河流划分为几个窄的流，可以放到后面不同的slot上运行。

窗口生命周期

举个例子：对于一个 5 分钟的 Tumbling 窗口，允许 1 分钟的时延，Flink将 在12:00到12:05这段时间内第一个元素到达时创建窗口，当 watermark 超过12:06时，该窗口将被移除。

Window函数

函数里定义了应用于窗口（Window）内容的计算逻辑

Trigger（触发器）

Trigger 指定了窗口函数什么条件下可以被触发，触发器还可以在窗口存在的时间里清除窗口中的元素，但是新数据依然可以添加到窗口中。

Evictor（驱逐者）

将在触发器触发之后 或 函数被应用前后，清除窗口中的元素。

关于Session Window

Session Window 会为每个到达的 Event 创建一个窗口，不同窗口间的距离如果小于定义的 Session Window 的值时，则合并这些窗口。