Uses of Class
org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder

Packages that use OperatorCoordinatorHolder

Package	Description
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.operators.coordination
org.apache.flink.runtime.scheduler

Uses of OperatorCoordinatorHolder in org.apache.flink.runtime.executiongraph

Methods in org.apache.flink.runtime.executiongraph that return types with arguments of type OperatorCoordinatorHolder

Modifier and Type	Method and Description
Collection<OperatorCoordinatorHolder>	ExecutionJobVertex.getOperatorCoordinators()

Uses of OperatorCoordinatorHolder in org.apache.flink.runtime.operators.coordination

Methods in org.apache.flink.runtime.operators.coordination that return OperatorCoordinatorHolder

Modifier and Type	Method and Description
static OperatorCoordinatorHolder	OperatorCoordinatorHolder.create(SerializedValue<OperatorCoordinator.Provider> serializedProvider, ExecutionJobVertex jobVertex, ClassLoader classLoader, CoordinatorStore coordinatorStore)

Uses of OperatorCoordinatorHolder in org.apache.flink.runtime.scheduler

Method parameters in org.apache.flink.runtime.scheduler with type arguments of type OperatorCoordinatorHolder

Modifier and Type	Method and Description
void	DefaultOperatorCoordinatorHandler.registerAndStartNewCoordinators(Collection<OperatorCoordinatorHolder> coordinators, ComponentMainThreadExecutor mainThreadExecutor)
void	OperatorCoordinatorHandler.registerAndStartNewCoordinators(Collection<OperatorCoordinatorHolder> coordinators, ComponentMainThreadExecutor mainThreadExecutor) Register and start new operator coordinators.