public static interface OperatorCoordinator.Provider extends Serializable
OperatorCoordinator.Context to 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
OperatorCoordinator, using the given context.
Gets the ID of the operator to which the coordinator belongs.
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.