Flink SQL 分组窗口函数 Group Window 实战

Posted 2022-10-07 @SmartSi

传送门：Flink 系统性学习笔记

---

Flink 1.13.5

在 Flink 1.12 之前的版本中，Table API 和 SQL 提供了一组分组窗口 Group Window 函数，常用的时间窗口如滚动窗口、滑动窗口、会话窗口都有对应的实现，具体在 SQL 中调用 TUMBLE()、HOP()、SESSION() 分组窗口函数即可。分组窗口的功能比较有限，只支持窗口聚合，所以在 Flink 1.12 之后的版本中不再推荐使用 Group Window 函数。而是推荐使用功能更加强大以及更有效的 Window TVF，具体请查阅 Flink SQL 窗口表值函数 Window TVF 实战。

Group Window 函数通过 SQL 查询的 GROUP BY 子句来定义。就像使用常规 GROUP BY 子句一样查询，但是 GROUP BY 子句会包含一个分组窗口函数。

下面我们详细看一下三个分组窗口 Group Window 函数具体是如何使用的。

1. TUMBLE

滚动窗口的窗口大小是固定不变的，并且窗口和窗口之间的数据不会重合。在 Flink SQL 中通过 TUMBLE(time