窗口函数

本文介绍流引擎内建函数中的窗口函数。

WINDOW_START

返回当前窗口的开始时间。

语法

WINDOW_START()

示例

SELECT item, SUM(price), WINDOW_START() AS windowStartTime FROM orders window TUMBLING (  SIZE 1 MINUTE) GROUP BY item;

WINDOW_END

返回当前窗口的结束时间。

语法

WINDOW_END()

示例

SELECT item, SUM(price), WINDOW_END() AS windowEndTime FROM orders window TUMBLING (  SIZE 1 MINUTE) GROUP BY item;

FIRST_VALUE

返回指定列当前行所对应窗口的第一条数据的值。

语法

FIRST_VALUE(col)

示例

SELECT item, FIRST_VALUE(price) as StartTime FROM orders window TUMBLING (  SIZE 1 MINUTE) GROUP BY item;

LAST_VALUE

返回当前行所对应窗口的最后一条数据的值。

语法

LAST_VALUE(col)

示例

SELECT item, LAST_VALUE(price) as EndTime FROM orders window TUMBLING (  SIZE 1 MINUTE) GROUP BY item;