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 |
create(OperatorCoordinator.Context context)
Creates the
OperatorCoordinator , using the given context. |
OperatorID |
getOperatorId()
Gets the ID of the operator to which the coordinator belongs.
|
OperatorID getOperatorId()
OperatorCoordinator create(OperatorCoordinator.Context context) throws Exception
OperatorCoordinator
, using the given context.Exception
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.