【大数据】说说Flink中的窗口（分类、生命周期、触发、划分）（约300字）

说说Flink中的窗口（分类、生命周期、触发、划分）

1）窗口分类： Keyed Window和Non-keyed Window
基于时间：滚动、滑动、会话
基于数量：滚动、滑动
2）Window口的4个相关重要组件：
 assigner（分配器）：如何将元素分配给窗口
 function（计算函数）：为窗口定义的计算。其实是一个计算函数，完成窗口内容的计算。
 triger（触发器）：在什么条件下触发窗口的计算
 evictor（退出器）：定义从窗口中移除数据
3）窗口的划分：如，基于事件时间的滚动窗口
start=按照数据的事件时间向下取窗口长度的整数倍
end=start+size
比如开了一个10s的滚动窗口，第一条数据是857s，那么它属于[850s,860s)
4）窗口的创建：当属于某个窗口的第一个元素到达，Flink就会创建一个窗口，
5）窗口的销毁：当时间超过其结束时间+用户指定的允许延迟时间（Flink保证只删除基于时间的窗口，而不能删除其他类型的窗口，例如全局窗口）。
6）窗口为什么左闭右开：属于窗口的最大时间戳=end-1ms
7）窗口什么时候触发：如基于事件时间的窗口 watermark>=end-1ms