flink时间系统系列之窗口函数中的应用分析

flink时间系统系列篇幅目录：

一、[时间系统概述介绍](http://mp.weixin.qq.com/s?__biz=MzU5MTc1NDUyOA==&mid=2247483748&idx=1&sn=ac1817f9b1fffaa0440e4afccf1519af&chksm=fe2b652bc95cec3d73f1fc3390eabeaa576d8d2e8d202ab2e94e4ace5f2b827a1c58db8de740&scene=21#wechat_redirect)

二、[Processing Time源码分析 ](http://mp.weixin.qq.com/s?__biz=MzU5MTc1NDUyOA==&mid=2247483756&idx=1&sn=6430e7c02ca0c278ee0e272feaa38624&chksm=fe2b6523c95cec350f4e79a7cf3a0c36ba21c8ba1c85884d55fab73ca330890852718facb185&scene=21#wechat_redirect)

三、[Event Time源码分析](http://mp.weixin.qq.com/s?__biz=MzU5MTc1NDUyOA==&mid=2247483768&idx=1&sn=b292c48398d0c1ecaa83a53757912f51&chksm=fe2b6537c95cec2104711935f50d07cff4f37c5c77b003b42f9ce08a6ed7bb38bb75ed449d6d&scene=21#wechat_redirect)

四、时间系统在窗口函数中的应用分析

五、ProcessFunction 使用分析

六、实例讲解：如何做定时输出

  在flink中窗口划分可以基于时间、基于数量，我们这里所涉及到的窗口是针对时间类型窗口：processing-time window与event-time window，时间系统在时间窗口应用主要用来注册窗口触发时间点，来决定窗口什么时候开始执行窗口函数。接下来从源码的角度分析窗口是如何使用时间系统的。

以WindowOperator 为入口，这是窗口操作中的核心类，它继承了AbstractUdfStreamOperator并且实现了Triggerable接口，而AbstractUdfStreamOperator 又继承了AbstractStreamOperator，

image

首先会在WindowOperator.open 初始化方法中，注册了一个名为window-timers 的InternalTimerService服务，由前面的分析可知使用该服务可以注册一些定时器，在窗口中注册窗口触发的定时器，

image

注册流程在WindowOperator.processElement方法中，不管是处理时间窗口还是事件时间窗口都会调用registerCleanupTimer方法完成真正的定时注册，

image

该方法首先会计算出窗口的触发时间，然后按照时间类型进行注册，triggerContext表示的是WindowOperator.Context对象，在注册相应类型触发器时，实际上会调用在WindowOperator 在open 中初始化的InternalTimerService来完成相应的注册定时器，

image

之后的流程就会按照前面几个篇幅的分析完成成具体的注册逻辑。

   在Processing time与event time源码分析中提到，定时器的触发操作最后会调用Triggerable的onProcessingTime或者onEventTime 方法，而在WindowOperator.open方法中，初始的InternalTimerService传入的Triggerable

对象正好是this,也就是WindowOperator对象，也就是说在窗口中定时器的触发会调用WindowOperator的onEventTime或者onProcessingTime方法，在这些方法里面会执行窗口函数触发逻辑判断、窗口函数操作与状态清除的工作。

  以上就是关于时间系统如何在窗口函数中应用。

企业微信截图_552a5b2d-e64f-41e2-be6b-865f5dc7a6dd.png

flink时间系统系列之窗口函数中的应用分析

推荐阅读更多精彩内容