95-860-040-源码-定时器-SystemProcessingTimeService简介

Posted 2021-10-17 九师兄

文章目录

• 1.世界
• 2.概述
• 3.SystemProcessingTimeService
• • 3.1 拓扑图
  • 3.2 概述
  • 3.3 .getCurrentProcessingTime
  • 3.4 timerService
  • 3.5 registerTimer
  • 3.6 scheduleAtFixedRate

1.世界

2.概述

​ flink 中的定时器，顾名思义，定时器就是用户指定一个未来的时间，当时间到达的时候，会调用用户设置的回调函数。flink 中的进程时间定时器和事件时间定时