Uses of Interface org.apache.flink.connector.base.source.reader.splitreader.SplitReader (Flink : Connectors : Base 2.1.1-cp1 API)

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(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.

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(Supplier<SplitReader<E,SplitT>> splitReaderSupplier)`	Creates a new SplitFetcherManager with a single I/O threads.
`SingleThreadFetcherManager(Supplier<SplitReader<E,SplitT>> splitReaderSupplier, org.apache.flink.configuration.Configuration configuration)`	Creates a new SplitFetcherManager with a single I/O threads.
`SingleThreadFetcherManager(Supplier<SplitReader<E,SplitT>> splitReaderSupplier, org.apache.flink.configuration.Configuration configuration, Consumer<Collection<String>> splitFinishedHook)`	Creates a new SplitFetcherManager with a single I/O threads.
`SplitFetcherManager(Supplier<SplitReader<E,SplitT>> splitReaderFactory, org.apache.flink.configuration.Configuration configuration)`	Create a split fetcher manager.
`SplitFetcherManager(Supplier<SplitReader<E,SplitT>> splitReaderFactory, org.apache.flink.configuration.Configuration configuration, Consumer<Collection<String>> splitFinishedHook)`	Create a split fetcher manager.