Uses of Interface
org.apache.flink.connector.base.source.reader.splitreader.SplitReader

Packages that use SplitReader

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

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

Constructor parameters in org.apache.flink.connector.base.source.reader with type arguments of type SplitReader

Constructor	Description
SingleThreadMultiplexSourceReaderBase(java.util.function.Supplier<SplitReader<E,SplitT>> splitReaderSupplier, 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.
SingleThreadMultiplexSourceReaderBase(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>> elementsQueue, java.util.function.Supplier<SplitReader<E,SplitT>> splitReaderSupplier, RecordEmitter<E,T,SplitStateT> recordEmitter, org.apache.flink.configuration.Configuration config, org.apache.flink.api.connector.source.SourceReaderContext context)	Deprecated. Please use SingleThreadMultiplexSourceReaderBase(Supplier, RecordEmitter, Configuration, SourceReaderContext) instead.

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

Methods in org.apache.flink.connector.base.source.reader.fetcher that return SplitReader

Modifier and Type	Method	Description
SplitReader<E,SplitT>	SplitFetcher.getSplitReader()

Constructor parameters in org.apache.flink.connector.base.source.reader.fetcher with type arguments of type SplitReader

Constructor	Description
SingleThreadFetcherManager(java.util.function.Supplier<SplitReader<E,SplitT>> splitReaderSupplier)	Creates a new SplitFetcherManager with a single I/O threads.
SingleThreadFetcherManager(java.util.function.Supplier<SplitReader<E,SplitT>> splitReaderSupplier, org.apache.flink.configuration.Configuration configuration)	Creates a new SplitFetcherManager with a single I/O threads.
SingleThreadFetcherManager(java.util.function.Supplier<SplitReader<E,SplitT>> splitReaderSupplier, org.apache.flink.configuration.Configuration configuration, java.util.function.Consumer<Collection<String>> splitFinishedHook)	Creates a new SplitFetcherManager with a single I/O threads.
SingleThreadFetcherManager(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>> elementsQueue, java.util.function.Supplier<SplitReader<E,SplitT>> splitReaderSupplier)	Deprecated. Please use SingleThreadFetcherManager(Supplier, Configuration) instead.
SingleThreadFetcherManager(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>> elementsQueue, java.util.function.Supplier<SplitReader<E,SplitT>> splitReaderSupplier, org.apache.flink.configuration.Configuration configuration)	Deprecated. Please use SingleThreadFetcherManager(Supplier, Configuration) instead.
SingleThreadFetcherManager(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>> elementsQueue, java.util.function.Supplier<SplitReader<E,SplitT>> splitReaderSupplier, org.apache.flink.configuration.Configuration configuration, java.util.function.Consumer<Collection<String>> splitFinishedHook)	Deprecated. Please use SingleThreadFetcherManager(Supplier, Configuration, Consumer) instead.
SplitFetcherManager(java.util.function.Supplier<SplitReader<E,SplitT>> splitReaderFactory, org.apache.flink.configuration.Configuration configuration)	Create a split fetcher manager.
SplitFetcherManager(java.util.function.Supplier<SplitReader<E,SplitT>> splitReaderFactory, org.apache.flink.configuration.Configuration configuration, java.util.function.Consumer<Collection<String>> splitFinishedHook)	Create a split fetcher manager.
SplitFetcherManager(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>> elementsQueue, java.util.function.Supplier<SplitReader<E,SplitT>> splitReaderFactory, org.apache.flink.configuration.Configuration configuration)	Deprecated. Please use SplitFetcherManager(Supplier, Configuration) instead.
SplitFetcherManager(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>> elementsQueue, java.util.function.Supplier<SplitReader<E,SplitT>> splitReaderFactory, org.apache.flink.configuration.Configuration configuration, java.util.function.Consumer<Collection<String>> splitFinishedHook)	Deprecated. Please use SplitFetcherManager(Supplier, Configuration, Consumer) instead.