在Flink中,有一个重要的概念,就是窗口,我也常用到,这里记录一下用法以及一些概念。
本文依据最新版Flink1.16.1版本来说明。
一般真实的流都是无界的,要处理无界的数据,就需要把无界数据切为有界数据。
窗口(window)就是将无限流切割为有限流的一种方式。
它会将流数据分发到有限大小的桶(bucket)中进行分析。
Flink 提供了非常完善的窗口机制,这是 Flink 最大的亮点之一。
Flink中的Windows按类型大致可分为两种:时间窗口和计数窗口:
根据窗口实现原理的不同分成三类:
滚动窗口(Tumbling Window)滑动窗口(Sliding Window)会话窗口(Session Window)
根据窗口实现原理的不同分成两类:
滚动计数窗口(Tumbling Window)滑动计数窗口(Sliding Windo
上一篇:网络安全实验 反汇编 逆向实验
下一篇:【如何和陌生人攀上关系?】