草庐IT

TumblingEventTimeWindows

全部标签

TumblingEventTimeWindows(滚动时间窗口)和 SlidingEventTimeWindows(滑动时间窗口)开窗的解析

滚动时间窗口,窗口之前是首尾相接的滑动事件窗口,窗口之间是有重叠的,也就是说一个事件会出现在不同的窗口 滚动时间窗口(TumblingEventTime)的开始结束时间是如何计算的呢?一看源码便知: 红框即为窗口开窗时间具体计算公式如下:例如,给定一个时间戳1665103475,窗口大小设定为15s,offset默认为0,开窗时间:1665103475-(1665103475-0+15000)%15000 =  1665090000结束时间:start+this.size即1665090000+15000=1665105000此窗口即为 1665090000~ 1665105000滑动时间窗口

Flink中事件时间和处理时间(TumblingEventTimeWindows TumblingProcessingTimeWindows)

TumblingEventTimeWindows和TumblingProcessingTimeWindows是Flink中两种不同的窗口类型.区别如下:时间类型:TumblingEventTimeWindows是基于事件时间的窗口类型,可以通过设置Watermark和EventTimeCharacteristic来确定事件时间;而TumblingProcessingTimeWindows是基于处理时间的窗口类型,时间由Flink运行时系统确定。窗口大小的选取:在TumblingEventTimeWindows中,窗口大小通常由用户设定的时间长度、Watermark和窗口策略共同决定;而在Tum