0
点赞
收藏
分享

微信扫一扫

tumble window的一个测试实例

岁月不饶人老不正经 2022-02-18 阅读 35

定义:

滚动窗口(TUMBLE):将每个元素分配到一个指定大小的窗口中

Event Time:事件产生的时间,记录的是设备生产(或者存储)事件的时间

Watermarks:用来定义何时停止等待较早的事件

例:

一分钟大小的滚动窗口

无限流的数据会根据时间划分为:[00:00:00, 00:01:00),[00:01:00,00:02:00), [00:02:00, 00:03:00) ...

语法:

TUMBLE函数用在GROUP BY子句中,用来定义滚动窗口。

标识函数:

使用标识函数选出窗口的起始时间或者结束时间,窗口的时间属性用于下级Window的聚合。

窗口标识函数

返回类型

描述

TUMBLE_START(time-attr, size-interval)

TIMESTAMP

返回窗口的起始时间(包含边界)。例如[00:10,00:15]窗口,返回00:10。

TUMBLE_END(time-attr, size-interval)

TI

举报

相关推荐

0 条评论