-
鑫鑫
·sessionwindow
·timeWindow(Time.seconds(5))
timeWindow(Time.seconds(5), Time.seconds(3))
·countWindow(5)
countWindow(5,3)
-
滚动窗口(Tumbling Window):按固定时间切分,窗口与窗口之间没有重叠
滑动窗口(Sliding Window):在滚动窗口之上加了一个滑动时间,允许窗口之间重叠
会话窗口(Session Window):窗口的触发的条件是Session Gap,超过一定时间没有数据活跃,触发窗口计算
数量窗口(Count Window):按数据的数量划分窗口
什么是Flink WaterMark机制?
标签: 窗口、window、flink、重叠、滚动
笔试题
刷题
简历模板
AI算法
大数据
内推
内推: