Package org.apache.flink.runtime.source.coordinator

Class Summary

Class	Description
ExecutorNotifier	This class is used to coordinate between two components, where one component has an executor following the mailbox model and the other component notifies it when needed.
SourceCoordinator<SplitT extends SourceSplit,EnumChkT>	The default implementation of the OperatorCoordinator for the Source.
SourceCoordinator.WatermarkElement	The watermark element for HeapPriorityQueue.
SourceCoordinatorContext<SplitT extends SourceSplit>	A context class for the OperatorCoordinator.
SourceCoordinatorProvider<SplitT extends SourceSplit>	The provider of SourceCoordinator.
SourceCoordinatorProvider.CoordinatorExecutorThreadFactory	A thread factory class that provides some helper methods.
SourceCoordinatorSerdeUtils	A serialization util class for the SourceCoordinator.
SplitAssignmentTracker<SplitT extends SourceSplit>	A class that is responsible for tracking the past split assignments made by SplitEnumerator.