数据湖探索 DLI-窗口函数:窗口函数简介

时间:2024-11-16 13:21:44

窗口函数简介

Apache Flink 提供3个内置的窗口表值函数:TUMBLE,HOP 和 CUMULATE。

窗口表值函数的返回值包括原生列和附加的三个指定窗口的列,分别是:“window_start”,“window_end”,“window_time”。

在批计算模式,window_time 是 TIMESTAMP 或者 TIMESTAMP_LTZ 类型(具体哪种类型取决于输入的时间字段类型)的字段。 window_time 字段用于后续基于时间的操作,例如:其他的窗口表值函数,或者interval joins,over aggregations。 它的值总是等于 window_end - 1ms。

support.huaweicloud.com/sqlref-flink-dli/dli_08_15070.html