数据湖探索 DLI-窗口:TUMBLE WINDOW扩展

时间:2024-07-01 21:07:18

TUMBLE WINDOW扩展

功能描述

DLI TUMBLE函数功能增强主要包括以下功能:
  • TUMBLE窗口周期性触发,控制延迟

    TUMBLE窗口结束之前,可以根据设置的触发频率周期性地触发窗口,输出从窗口开始时间到当前周期时间窗口内的计算结果值,但不影响最终窗口输出值,从而在窗口结束前的每个周期都可以看到最新的结果。

  • 提高数据的精确性

    在窗口结束后,允许设置延迟时间。根据设置的延迟时间,每到达一个迟到数据,则更新窗口的输出结果

注意事项

若使用insert语句将结果写入sink中,则sink需要支持upsert模式。

语法格式

TUMBLE(time_attr, window_interval, period_interval, lateness_interval)

语法示例

例如当前time_attr属性列为:testtime,窗口时间间隔为10秒,语法示例为:
TUMBLE(testtime, INTERVAL '10' SECOND, INTERVAL '10' SECOND, INTERVAL '10' SECOND)
support.huaweicloud.com/sqlreference-dli/dli_08_0324.html