- Flink内核原理与实现
- 冯飞 崔鹏云 陈冠华编著
- 153字
- 2021-04-14 11:30:37
3.8 分布式ID
在分布式计算中,Flink对所有需要进行唯一标识的组件、对象提供了抽象类AbstractID,因为需要跨网络进行传递,所以该类实现了Serializable接口,需要比较唯一标识是否相同,所以也实现了Comparable接口。
分布式ID类体系如图3-38所示。
从图中可以看到,基本上Flink作业、资源管理、作业管理器、资源管理器、TaskManger等都有各自的身份标识实现。
![](https://epubservercos.yuewen.com/AB30C5/19773741101350906/epubprivate/OEBPS/Images/76_01.jpg?sign=1739323976-Vjb60xjKq9r7XmZE17NmlfuFl4yaYjaH-0-8b94f42b205e4b6bfc43321e0ded072c)
图3-38 分布式ID类体系