95-860-050-源码-定时器-InternalTimeServiceManager

Posted 2021-10-19 九师兄

文章目录

• 1.世界
• 2.概述
• 3.getInternalTimerService
• 4.advanceWatermark

1.世界

2.概述

​ InternalTimeServiceManager 用于给 AbstractStreamOperator 操作符提供访问 InternalTimerServiceImpl ``的接口，也可以这么认为，InternalTimeServiceManager集中管理了InternalTimerServiceImpl`.

InternalTimeServiceManager 中用一个 map 存储 String 到 InternalTimerServiceImpl 的映射

private