Flink内核原理与实现
上QQ阅读APP看书,第一时间看更新

3.8 分布式ID

在分布式计算中,Flink对所有需要进行唯一标识的组件、对象提供了抽象类AbstractID,因为需要跨网络进行传递,所以该类实现了Serializable接口,需要比较唯一标识是否相同,所以也实现了Comparable接口。

分布式ID类体系如图3-38所示。

从图中可以看到,基本上Flink作业、资源管理、作业管理器、资源管理器、TaskManger等都有各自的身份标识实现。

图3-38 分布式ID类体系