本文主要是介绍Event Time源码分析,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
flink 中Processing Time也就是处理时间在watermark定时生成、ProcessFunction中定时器与时间类型的窗口中都有使用,但是其内部是如何实现注册定时器、如何调用、如何容错保证在任务挂掉在下次重启仍然能够触发任务执行,都是我们今天的主题。首先需要了解一下在flink内部时间系统是由哪些类来共同完成这件事,下面画了一个简易的类关系图:
AbstractStreamOperator: flink runtime 的核心operator, 包含了一个operator生命周期所有的执行方法(后面做单独介绍),其包含一个InternalTimeServiceManager的对象,在initializeState完成初始化;
InternalTimeServiceManager:flink 内部提供时间服务的manager, getInternalTimerService负责注
这篇关于Event Time源码分析的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!