public static interface OperatorCoordinator.Provider extends Serializable
OperatorCoordinator.Contextto pass to the OperatorCoordinator. This method is, for example, called on the job manager when the scheduler and execution graph are created, to instantiate the OperatorCoordinator.
The factory is
Serializable, because it is attached to the JobGraph and is part of
the serialized job graph that is sent to the dispatcher, or stored for recovery.
|Modifier and Type||Method and Description|
Gets the ID of the operator to which the coordinator belongs.
OperatorCoordinator create(OperatorCoordinator.Context context) throws Exception
OperatorCoordinator, using the given context.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.