flink window 框架详细解读

2022-12-23 06:37| 来源: 网络整理| 查看: 265

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分钟) 使用场景

【本文地址】

今日新闻