滑动窗口_开发指南（Flink）_实时计算（流计算）_敏捷版通用版本

本文为您介绍如何使用实时计算滑动窗口函数。

定义

滑动窗口（HOP），也被称作Sliding Window。不同于滚动窗口，滑动窗口的窗口可以重叠。

滑动窗口有两个参数： slide 和 size 。 slide 为每次滑动的步长， size 为窗口的大小。

通常，大部分元素符合多个窗口情景，窗口是重叠的。因此，滑动窗口在计算移动平均数（moving averages）时很实用。例如，计算过去5分钟数据的平均值，每10秒钟更新一次，可以设置 slide 为 10 秒， size 为 5 分钟。下图为您展示间隔为30秒，窗口大小为1分钟的滑动窗口。

HOP函数用在group by子句中，用来定义滑动窗口。

HOP(<time-attr>, <slide-interval>,<size-interval>)
<slide-interval>: INTERVAL 'string' timeUnit
<size-interval>: INTERVAL 'string' timeUnit

窗口标识函数	返回类型	描述
`HOP_START(time-attr, size-interval)`	TIMESTAMP	返回窗口的起始时间（包含边界）。例如 `[00:10, 00:15)` 窗口，返回 `00:10` 。
`HOP_END(time-attr, size-interval)`	TIMESTAMP	返回窗口的结束时间（包含边界）。例如 `[00:00, 00:15)` 窗口，返回 `00:15` 。
`HOP_ROWTIME(time-attr, size-interval)`	TIMESTAMP（rowtime-attr）	返回窗口的结束时间（不包含边界）。例如 `[00:00, 00:15)` 窗口，返回 `00:14:59.999` 。返回值是一个rowtime attribute，即可以基于该字段做时间类型的操作，例如级联窗口，只能用在基于event time的window上。