Flink 窗口分配器 WindowAssigner

传送门：Flink 系统性学习笔记

---

Windows(窗口)是处理无限数据流的核心。窗口将流分解成有限大小的"桶"，在上面可以进行各种计算。本文将重点介绍 Flink 中的窗口分配器 WindowAssigner。新建一个窗口算子一般必须要指定两个窗口组件：

• 一个用于决定输入流中的元素如何划分的窗口分配器 WindowAssigner。窗口分配器将元素分配到一个或者多个窗口中。
• 另一个是用于处理分配到窗口中元素的窗口函数 WindowFunction。

如下代码展示了如何在 KeyedStream 和非 KeyedStream 上指定窗口分配器和窗口函数（以及可选的触发器和剔除器，后面文章会具体介绍）的示例：

// keyedStream
keyedStream
       .keyBy(...)          <
1
2