Flink 源码解读系列 DataStream 时间服务管理器 TimeServiceManager 设计与实现
Posted @SmartSi
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Flink 源码解读系列 DataStream 时间服务管理器 TimeServiceManager 设计与实现相关的知识，希望对你有一定的参考价值。
Flink 1.15.2
1. InternalTimeServiceManager 设计
Flink 1.12.0 版本将 InternalTimeServiceManager 重构为一个接口，目标是可以自定义实现不同的 InternalTimerService 实现，具体查阅FLINK-19288。当前版本下，InternalTimeServiceManager 提供了2个核心方法，一个是创建 InternalTimerService 实例的 getInternalTimerService，另一个就是通知所有 InternalTimerService 实例 Watermark 更新的 advanceWatermark：
@Internal
public interface InternalTimeServiceManager<K以上是关于Flink 源码解读系列 DataStream 时间服务管理器 TimeServiceManager 设计与实现的主要内容，如果未能解决你的问题，请参考以下文章
Flink 源码解读系列 DataStream 数据流元素 StreamElement
Flink 源码解读系列 DataStream 数据流元素 StreamElement
Flink 源码解读系列 DataStream 窗口分配器 WinowAssigner