Flink 窗口分配器 WindowAssigner
Posted @SmartSi
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Flink 窗口分配器 WindowAssigner相关的知识，希望对你有一定的参考价值。
传送门：Flink 系统性学习笔记
Windows(窗口)是处理无限数据流的核心。窗口将流分解成有限大小的"桶"，在上面可以进行各种计算。本文将重点介绍 Flink 中的窗口分配器 WindowAssigner。新建一个窗口算子一般必须要指定两个窗口组件：
- 一个用于决定输入流中的元素如何划分的窗口分配器 WindowAssigner。窗口分配器将元素分配到一个或者多个窗口中。
- 另一个是用于处理分配到窗口中元素的窗口函数 WindowFunction。
如下代码展示了如何在 KeyedStream 和非 KeyedStream 上指定窗口分配器和窗口函数（以及可选的触发器和剔除器，后面文章会具体介绍）的示例：
// keyedStream
keyedStream
.keyBy(...) <以上是关于Flink 窗口分配器 WindowAssigner的主要内容，如果未能解决你的问题，请参考以下文章
Flink 源码解读系列 DataStream 窗口分配器 WinowAssigner