Flink源码阅读：窗口

杆树 3 天前

程序园永久vip申请，500美金$，无限下载程序园所有程序/软件/数据/等

前文我们梳理了 Watermark 相关的源码，Watermark 的作用就是用来触发窗口，本文我们就一起看一下窗口相关的源码。
写在前面

在Flink学习笔记：窗口一文中，我们介绍了窗口的分类以及基本的用法。按照处理数据流的类型划分，Flink 可以分为 Keyed Window 和 Non-Keyed Window，它们的用法如下：
[code]stream .keyBy(...)