Interface | Description |
---|---|
SharedProgressAlignerListener |
The listener of the
SharedProgressAligner . |
Class | Description |
---|---|
HeadOperatorCoordinator |
The OperatorCoordinator of the
HeadOperator , it notifies the SharedProgressAligner when received aligned event from the operator, and emit the globally
aligned event back after one round is globally aligned. |
HeadOperatorCoordinator.HeadOperatorCoordinatorProvider |
The factory of
HeadOperatorCoordinator . |
SharedProgressAligner |
The progress aligner shared between multiple
HeadOperatorCoordinator . |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.