org.apache.flink.runtime.source.coordinator

Class SourceCoordinatorProvider<SplitT extends SourceSplit>

java.lang.Object

org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator.Provider

org.apache.flink.runtime.source.coordinator.SourceCoordinatorProvider<SplitT>

All Implemented Interfaces:

Serializable, OperatorCoordinator.Provider

public class SourceCoordinatorProvider<SplitT extends SourceSplit>
extends RecreateOnResetOperatorCoordinator.Provider

The provider of SourceCoordinator.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SourceCoordinatorProvider.CoordinatorExecutorThreadFactory A thread factory class that provides some helper methods.

Constructor Summary

Constructors

Constructor and Description
SourceCoordinatorProvider(String operatorName, OperatorID operatorID, Source<?,SplitT,?> source, int numWorkerThreads, WatermarkAlignmentParams alignmentParams, String coordinatorListeningID) Construct the SourceCoordinatorProvider.

Method Summary

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

Methods inherited from class org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator.Provider

create, create, getOperatorId

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SourceCoordinatorProvider

public SourceCoordinatorProvider(String operatorName,
                                 OperatorID operatorID,
                                 Source<?,SplitT,?> source,
                                 int numWorkerThreads,
                                 WatermarkAlignmentParams alignmentParams,
                                 @Nullable
                                 String coordinatorListeningID)

Construct the SourceCoordinatorProvider.

Parameters:

operatorName - the name of the operator.

operatorID - the ID of the operator this coordinator corresponds to.

source - the Source that will be used for this coordinator.

numWorkerThreads - the number of threads the should provide to the SplitEnumerator for doing async calls. See SplitEnumeratorContext.callAsync().

Method Detail

getCoordinator

public OperatorCoordinator getCoordinator(OperatorCoordinator.Context context)

Specified by:

getCoordinator in class RecreateOnResetOperatorCoordinator.Provider