Class | Description |
---|---|
CoordinatorCheckpointEvent |
Coordinator received the request of checkpoints.
|
GloballyAlignedEvent |
The event sent from
HeadOperatorCoordinator to HeadOperator to notify a round is
globally aligned and whether the iteration should terminate. |
SubtaskAlignedEvent |
The event sent from
HeadOperator to HeadOperatorCoordinator to notify the subtask
has received the EpochWatermark for the specified round. |
TerminatingOnInitializeEvent |
Notifies the
HeadOperatorCoordinator that the status has been terminating on startup so
that the coordinator would not emit CoordinatorCheckpointEvent . |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.