flink sql 窗口

Flink SQL 中的窗口是将无限数据流划分为有限大小的块，以便进行有限的处理和聚合。窗口可以按照时间或数据数量进行定义。Flink SQL 支持以下类型的窗口：

1. 滚动窗口（Tumbling Window）：滚动窗口是一系列固定大小的、不重叠的时间段，按照固定的时间长度进行滚动，例如每 5 秒一个窗口。

2. 滑动窗口（Sliding Window）：滑动窗口是一系列大小固定、可以有重叠的时间段，按照固定的时间长度进行滑动，例如每 5 秒滑动一次，窗口大小为 10 秒。

3. 会话窗口（Session Window）：会话窗口是一组活动时间段的集合，这些时间段之间的间隔小于或等于指定的时间长度。会话窗口不需要固定的窗口长度，而是根据数据本身的属性动态计算。

Flink SQL 中的窗口可以通过以下语法进行定义：

SELECT ...
FROM ...
WHERE ...
GROUP BY ...
WINDOW <window_type> ( <window_property> )

其中，`<window_type>` 可以是 `TUMBLING`, `SLIDING` 或 `SESSION`，`<window_property>` 取决于窗口类型，例如：

- 对于滚动窗口，可以使用 `SIZE` 或 `TIME` 参数指定窗口大小或时间长度，例如 `WINDOW TUMBLING (SIZE 5 MINUTES)`。

- 对于滑动窗口，可以使用 `SIZE` 和 `SLIDE` 参数分别指定窗口大小和滑动步长，例如 `WINDOW SLIDING (SIZE 5 MINUTES, SLIDE 1 MINUTE)`。

- 对于会话窗口，可以使用 `GAP` 参数指定最大间隔时间，例如 `WINDOW SESSION (GAP 5 MINUTES)`。