flink的时间窗口生命周期是怎么样的?

提问者:帅平 问题分类:大数据

flink的时间窗口生命周期是怎么样的?

2 个回答
Rae
Rae 管理员

举个案例说明下这个声明周期的状态,例如:创建一个没3分钟翻滚一次切允许延迟时间为1分钟的窗口的生命周期流程如下:

1、创建一个00:00到00:03的新窗口
2、带有时间戳的第一个元素落入00:00到00:03的时间间隔时,创建窗口。
3、当时间达到00:03时,同时时间水位线经过00:04时间戳的时候,此窗口将被删除。

发布于:2个月前 (10-08)
Rae
Rae 管理员

flink的时间窗口生命周期主要分为3个阶段,分别是:

1、创建:当属于该窗口的第一个元素到达时就会创建该窗口。
2、销毁:当时间超过  窗口的结束时间戳+用户指定的延迟时间  时就会销毁
3、移除:窗口最终被移除掉。

发布于:2个月前 (10-08)
我来回答