Uses of Class
org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager

Packages that use SplitFetcherManager

Package	Description
org.apache.flink.connector.base.source.reader
org.apache.flink.connector.base.source.reader.fetcher

Uses of SplitFetcherManager in org.apache.flink.connector.base.source.reader

Fields in org.apache.flink.connector.base.source.reader declared as SplitFetcherManager

Modifier and Type	Field	Description
protected SplitFetcherManager<E,SplitT>	SourceReaderBase.splitFetcherManager	The split fetcher manager to run split fetchers.

Constructors in org.apache.flink.connector.base.source.reader with parameters of type SplitFetcherManager

Constructor	Description
SourceReaderBase(SplitFetcherManager<E,SplitT> splitFetcherManager, RecordEmitter<E,T,SplitStateT> recordEmitter, org.apache.flink.configuration.Configuration config, org.apache.flink.api.connector.source.SourceReaderContext context)	The primary constructor for the source reader.
SourceReaderBase(SplitFetcherManager<E,SplitT> splitFetcherManager, RecordEmitter<E,T,SplitStateT> recordEmitter, RecordEvaluator<T> eofRecordEvaluator, org.apache.flink.configuration.Configuration config, org.apache.flink.api.connector.source.SourceReaderContext context)
SourceReaderBase(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>> elementsQueue, SplitFetcherManager<E,SplitT> splitFetcherManager, RecordEmitter<E,T,SplitStateT> recordEmitter, org.apache.flink.configuration.Configuration config, org.apache.flink.api.connector.source.SourceReaderContext context)	Deprecated. Please use SourceReaderBase(SplitFetcherManager, RecordEmitter, Configuration, SourceReaderContext) instead.
SourceReaderBase(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>> elementsQueue, SplitFetcherManager<E,SplitT> splitFetcherManager, RecordEmitter<E,T,SplitStateT> recordEmitter, RecordEvaluator<T> eofRecordEvaluator, org.apache.flink.configuration.Configuration config, org.apache.flink.api.connector.source.SourceReaderContext context)	Deprecated. Please use SourceReaderBase(SplitFetcherManager, RecordEmitter, RecordEvaluator, Configuration, SourceReaderContext) instead.

Uses of SplitFetcherManager in org.apache.flink.connector.base.source.reader.fetcher

Subclasses of SplitFetcherManager in org.apache.flink.connector.base.source.reader.fetcher

Modifier and Type	Class	Description
class	SingleThreadFetcherManager<E,SplitT extends org.apache.flink.api.connector.source.SourceSplit>	A Fetcher Manager with a single fetching thread (I/O thread) that handles all splits concurrently.