1.视界

95-190-450-源码-window-Trigger-ContinuousProcessingTimeTrigger

2.概述

​ 短窗口的计算由于其窗口期较短,那么很快就能获取到结果,但是对于长窗口来说窗口时间比较长,如果等窗口期结束才能看到结果,那么这份数据就不具备实时性,大多数情况我们希望能够看到一个长窗口的结果不断变动的情况,对此Flink提供了ContinuousEventTimeTrigger连续事件时间触发器与ContinuousProcessingTimeTrigger连续处理时间触发器,指定一个固定时间间隔interval,不需要等到窗口结束才能获取结果,能够在固定的interval获取到窗口的中间结果。

2.1 拓扑图

95-190-450-源码-window-Trigger-ContinuousProcessingTimeTrigger

2.2 概述

ContinuousProcessingTimeTrigger 是一种根据给定的时间间隔连续触发的触发器,

ContinuousProcessingTimeTrigger 使用 ReducingStateDescriptor 接收一个 Min 实例来保存触发时间中的最小值,onProcessingTime 中会再次注册进程时间定时器.

相关文章:

  • 2021-10-13
  • 2021-10-06
  • 2022-12-23
  • 2021-10-21
  • 2022-12-23
  • 2022-12-23
  • 2021-06-16
  • 2021-12-01
猜你喜欢
  • 2021-11-17
  • 2022-01-21
  • 2021-09-07
  • 2021-08-31
  • 2021-08-06
  • 2021-12-30
  • 2021-07-04
相关资源
相似解决方案