flink1.12.x time window属性:size窗口大小、slide滑动间隔 和 Sliding滑动窗口、Tumbling滚动窗口

time window属性

size 窗口大小

统计这个时间段内的数据

slide 滑动间隔

间隔时间

滚动窗口(Tumbling Window)

如下图:

窗口大小(窗口长度、窗口宽度)是 10s,窗口滑动间隔是 10s,即:size = slide

意思:滑动 10s 统计最近 10s 的数据
特点:没有重叠
应用场景:最为广泛

滑动窗口(Sliding Window)

size > slide ,如每隔 5s 统计最近 10s 的数据

窗口长度固定,会有重叠

如下图:

窗口大小(窗口长度、窗口宽度)是 10s,窗口滑动间隔是 7s,即:size > slide

意思:滑动 7s 统计最近 10s 的数据
特点:有重叠
应用场景:类似微博热搜,每隔10分钟,统计计算最近24小时的热搜榜

size < slide 的 窗口

如下图:

窗口大小(窗口长度、窗口宽度)是 10s,窗口滑动间隔是 15s,即:size < slide

意思:每隔 15s 统计最近 10s 的数据
特点:每次计算会丢失 5s 数据
应用场景:几乎不用


原文出处:/show_1IX20QPkHKpO.html