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

Packages that use OperatorCoordinator.Context

Package	Description
org.apache.flink.runtime.operators.coordination
org.apache.flink.runtime.source.coordinator
org.apache.flink.streaming.api.operators.collect
org.apache.flink.table.runtime.operators.dynamicfiltering

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

Methods in org.apache.flink.runtime.operators.coordination with parameters of type OperatorCoordinator.Context

Modifier and Type	Method and Description
OperatorCoordinator	OperatorCoordinator.Provider.create(OperatorCoordinator.Context context) Creates the OperatorCoordinator, using the given context.
OperatorCoordinator	RecreateOnResetOperatorCoordinator.Provider.create(OperatorCoordinator.Context context)
protected OperatorCoordinator	RecreateOnResetOperatorCoordinator.Provider.create(OperatorCoordinator.Context context, long closingTimeoutMs)
protected abstract OperatorCoordinator	RecreateOnResetOperatorCoordinator.Provider.getCoordinator(OperatorCoordinator.Context context)

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

Methods in org.apache.flink.runtime.source.coordinator with parameters of type OperatorCoordinator.Context

Modifier and Type	Method and Description
OperatorCoordinator	SourceCoordinatorProvider.getCoordinator(OperatorCoordinator.Context context)

Constructors in org.apache.flink.runtime.source.coordinator with parameters of type OperatorCoordinator.Context

Constructor and Description
SourceCoordinatorContext(SourceCoordinatorProvider.CoordinatorExecutorThreadFactory coordinatorThreadFactory, int numWorkerThreads, OperatorCoordinator.Context operatorCoordinatorContext, SimpleVersionedSerializer<SplitT> splitSerializer, boolean supportsConcurrentExecutionAttempts)

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

Methods in org.apache.flink.streaming.api.operators.collect with parameters of type OperatorCoordinator.Context

Modifier and Type	Method and Description
OperatorCoordinator	CollectSinkOperatorCoordinator.Provider.create(OperatorCoordinator.Context context)

Uses of OperatorCoordinator.Context in org.apache.flink.table.runtime.operators.dynamicfiltering

Methods in org.apache.flink.table.runtime.operators.dynamicfiltering with parameters of type OperatorCoordinator.Context

Modifier and Type	Method and Description
protected OperatorCoordinator	DynamicFilteringDataCollectorOperatorCoordinator.Provider.getCoordinator(OperatorCoordinator.Context context)

Constructors in org.apache.flink.table.runtime.operators.dynamicfiltering with parameters of type OperatorCoordinator.Context

Constructor and Description
DynamicFilteringDataCollectorOperatorCoordinator(OperatorCoordinator.Context context, List<String> dynamicFilteringDataListenerIDs)