Uses of Interface
org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Provider

Packages that use OperatorCoordinator.Provider

Package	Description
org.apache.flink.runtime.jobgraph
org.apache.flink.runtime.operators.coordination
org.apache.flink.runtime.source.coordinator
org.apache.flink.streaming.api.graph
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.api.operators.collect

Uses of OperatorCoordinator.Provider in org.apache.flink.runtime.jobgraph

Methods in org.apache.flink.runtime.jobgraph that return types with arguments of type OperatorCoordinator.Provider

Modifier and Type	Method and Description
List<SerializedValue<OperatorCoordinator.Provider>>	JobVertex.getOperatorCoordinators()

Method parameters in org.apache.flink.runtime.jobgraph with type arguments of type OperatorCoordinator.Provider

Modifier and Type	Method and Description
void	JobVertex.addOperatorCoordinator(SerializedValue<OperatorCoordinator.Provider> serializedCoordinatorProvider)

Uses of OperatorCoordinator.Provider in org.apache.flink.runtime.operators.coordination

Classes in org.apache.flink.runtime.operators.coordination that implement OperatorCoordinator.Provider

Modifier and Type	Class and Description
static class	RecreateOnResetOperatorCoordinator.Provider The provider for a private RecreateOnResetOperatorCoordinator.

Method parameters in org.apache.flink.runtime.operators.coordination with type arguments of type OperatorCoordinator.Provider

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

Uses of OperatorCoordinator.Provider in org.apache.flink.runtime.source.coordinator

Classes in org.apache.flink.runtime.source.coordinator that implement OperatorCoordinator.Provider

Modifier and Type	Class and Description
class	SourceCoordinatorProvider<SplitT extends SourceSplit> The provider of SourceCoordinator.

Uses of OperatorCoordinator.Provider in org.apache.flink.streaming.api.graph

Methods in org.apache.flink.streaming.api.graph that return types with arguments of type OperatorCoordinator.Provider

Modifier and Type	Method and Description
Optional<OperatorCoordinator.Provider>	StreamNode.getCoordinatorProvider(String operatorName, OperatorID operatorID)

Uses of OperatorCoordinator.Provider in org.apache.flink.streaming.api.operators

Methods in org.apache.flink.streaming.api.operators that return OperatorCoordinator.Provider

Modifier and Type	Method and Description
OperatorCoordinator.Provider	CoordinatedOperatorFactory.getCoordinatorProvider(String operatorName, OperatorID operatorID) Get the operator coordinator provider for this operator.
OperatorCoordinator.Provider	SourceOperatorFactory.getCoordinatorProvider(String operatorName, OperatorID operatorID)

Uses of OperatorCoordinator.Provider in org.apache.flink.streaming.api.operators.collect

Classes in org.apache.flink.streaming.api.operators.collect that implement OperatorCoordinator.Provider

Modifier and Type	Class and Description
static class	CollectSinkOperatorCoordinator.Provider Provider for CollectSinkOperatorCoordinator.

Methods in org.apache.flink.streaming.api.operators.collect that return OperatorCoordinator.Provider

Modifier and Type	Method and Description
OperatorCoordinator.Provider	CollectSinkOperatorFactory.getCoordinatorProvider(String operatorName, OperatorID operatorID)