Flink系列之二Flink的窗口和水印

通常来讲,Window 就是用来对一个无限的流设置一个有限的集合,在有界的数据集上进行操作的一种机制。window 又可以分为基于时间(Time-based)的 window 以及基于数量(Count-based)的 window。

本文就 Flink 的窗口类型逐一分析,深入理解 fink 的窗口机制以及事件水印在数据流中的作用。

11月 ago