1. dataStream window
group window
time window 基于时间驱动
滚动时间窗口 tumble time window
滑动时间窗口 sliding time window
会话时间窗口 session time window
count window 基于数据驱动
滚动计数窗口 tumble count window
滑动计数窗口 sliding count window
2. sql window
group window (多对一)
滚动时间窗口 tumble time window
滑动时间窗口 sliding time window
会话时间窗口 session time window
over window (多对多)
滚动窗口
计数窗口
window TVF (1.13~)
sql tumble windw 滚动
sql hop window 滑动
sql session window 会话
sql cumulate window 累计
window TVF 优点:
1.语法标准化
2.性能优化。(local-global优化,distinct 解热点优化,迟到数据处理,支持grouping sets,cube,rollup等函数)
3. 解决 window + early-fire 或者 group by(1天) + minibatch(1分钟) 使用场景