2 个回答

举个案例说明下这个声明周期的状态,例如:创建一个没3分钟翻滚一次切允许延迟时间为1分钟的窗口的生命周期流程如下:
1、创建一个00:00到00:03的新窗口
2、带有时间戳的第一个元素落入00:00到00:03的时间间隔时,创建窗口。
3、当时间达到00:03时,同时时间水位线经过00:04时间戳的时候,此窗口将被删除。
发布于:3年前 (2022-10-08) IP属地:四川省

flink的时间窗口生命周期主要分为3个阶段,分别是:
1、创建:当属于该窗口的第一个元素到达时就会创建该窗口。
2、销毁:当时间超过 窗口的结束时间戳+用户指定的延迟时间 时就会销毁
3、移除:窗口最终被移除掉。
发布于:3年前 (2022-10-08) IP属地:四川省
我来回答
您需要 登录 后回答此问题!