Class and 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. |
Class and Description |
---|
TerminatingOnInitializeEvent
Notifies the
HeadOperatorCoordinator that the status has been terminating on startup so
that the coordinator would not emit CoordinatorCheckpointEvent . |
Class and Description |
---|
GloballyAlignedEvent
The event sent from
HeadOperatorCoordinator to HeadOperator to notify a round is
globally aligned and whether the iteration should terminate. |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.