SlidingWindow(滑动窗口)
滑动窗口
除了有一个固定的大小,还有一个定时滑动
的步长。例如,统计10分内的用户注册人数,每2分钟统计一次。那么Flink
就会每2分钟统计一次过去10分钟内的用户注册量。
这就像在一小步一小步地往前滑动一样,这也是滑动
窗口名字的由来。
如果同一个计算任务由多个滑动窗口组成,那么这些窗口在时间区间上会出现重叠。
原创大约 16 分钟
滑动窗口
除了有一个固定的大小,还有一个定时滑动
的步长。例如,统计10分内的用户注册人数,每2分钟统计一次。那么Flink
就会每2分钟统计一次过去10分钟内的用户注册量。
这就像在一小步一小步地往前滑动一样,这也是滑动
窗口名字的由来。
如果同一个计算任务由多个滑动窗口组成,那么这些窗口在时间区间上会出现重叠。