Skip to content

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).


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.