flink sql定义一个滑动窗口
时间: 2023-09-18 18:08:38 浏览: 180
【FlinkSql篇04】FlinkSql之窗口1
在 Flink SQL 中,可以使用以下语法定义一个滑动窗口:
```
SELECT ...
FROM ...
WINDOW TUMBLE (SIZE <size> INTERVAL <interval>)
```
其中,`SIZE` 表示窗口的大小,`INTERVAL` 表示窗口的滑动间隔。
例如,下面的语句定义了一个大小为 10 秒、每隔 5 秒滑动一次的滑动窗口:
```
SELECT ...
FROM ...
WINDOW TUMBLE (SIZE 10 SECONDS INTERVAL 5 SECONDS)
```
阅读全文