首页/数据/数仓建模速查/Flink 窗口:滚动、滑动、会话
湖仓与引擎63 条

Flink 窗口:滚动、滑动、会话

窗口按业务语义选择:滚动窗口不重叠、滑动窗口有步长、会话窗口按活跃间隔切分;窗口聚合必须结合水位线处理乱序。

数仓建模速查数据更新于 2026-10-12

窗口

窗口特征典型用途
滚动不重叠、等长每分钟点击数
滑动重叠、可设步长近 5 分钟指标
会话超时切分用户行为会话

窗口聚合

窗口聚合
SELECT window_start, window_end, store_id, count(1) AS order_cnt
FROM TABLE(
  TUMBLE(TABLE orders, DESCRIPTOR(event_time), INTERVAL '1' MINUTE)
)
GROUP BY window_start, window_end, store_id;
滑动窗口重叠会重复计算:窗口越大步长越小,资源消耗增长明显。

易错点

  • 滑动窗口结果直接求和,重复计数

数据来源与参考

  • Apache Flink 官方文档:Windows
​‌‌​​‌​​​‌‌​‌‌‌‌​‌‌​​​‌‌​‌‌‌​​‌‌​​‌​‌‌‌​​‌‌‌​​​‌​‌‌​‌​​‌​‌‌‌​​​‌​‌‌​‌​​‌​‌‌​​​‌‌​‌‌‌​‌​​​‌‌​‌‌‌‌​​‌​‌‌‌​​‌‌​​​‌‌​‌‌​‌‌‌‌​‌‌​‌‌​‌