BarrierCoordinatorMessage RPC Messages¶
BarrierCoordinatorMessage is an abstraction of RPC messages that tasks can send out using BarrierTaskContext operators for BarrierCoordinator to handle.
BarrierCoordinatorMessage is a Serializable (Java) (so it can be sent from executors to the driver over the wire).
Implementations¶
Sealed Trait
BarrierCoordinatorMessage is a Scala sealed trait which means that all of the implementations are in the same compilation unit (a single file).
Learn more in the Scala Language Specification.