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>|
|SourceCoordinatorContext<SplitT extends SourceSplit>||
A context class for the
|SourceCoordinatorProvider<SplitT extends SourceSplit>||
The provider of
A thread factory class that provides some helper methods.
A serialization util class for the
|SplitAssignmentTracker<SplitT extends SourceSplit>||
A class that is responsible for tracking the past split assignments made by
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.