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
org.apache.flink.connector.kafka.source.reader
org.apache.flink.connector.kafka.source.reader.fetcher
org.apache.flink.connector.pulsar.source.reader.fetcher
org.apache.flink.connector.pulsar.source.reader.split

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 and Description
SingleThreadMultiplexSourceReaderBase(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>> elementsQueue, java.util.function.Supplier<SplitReader<E,SplitT>> splitReaderSupplier, RecordEmitter<E,T,SplitStateT> recordEmitter, Configuration config, SourceReaderContext context) This constructor behaves like SingleThreadMultiplexSourceReaderBase(Supplier, RecordEmitter, Configuration, SourceReaderContext), but accepts a specific FutureCompletingBlockingQueue.
SingleThreadMultiplexSourceReaderBase(java.util.function.Supplier<SplitReader<E,SplitT>> splitReaderSupplier, RecordEmitter<E,T,SplitStateT> recordEmitter, Configuration config, 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 and Description
SplitReader<E,SplitT>	SplitFetcher.getSplitReader()

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

Constructor and Description
SingleThreadFetcherManager(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>> elementsQueue, java.util.function.Supplier<SplitReader<E,SplitT>> splitReaderSupplier) Creates a new SplitFetcherManager with a single I/O threads.
SingleThreadFetcherManager(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>> elementsQueue, java.util.function.Supplier<SplitReader<E,SplitT>> splitReaderSupplier, java.util.function.Consumer<Collection<String>> splitFinishedHook) Creates a new SplitFetcherManager with a single I/O threads.
SplitFetcherManager(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>> elementsQueue, java.util.function.Supplier<SplitReader<E,SplitT>> splitReaderFactory) Create a split fetcher manager.
SplitFetcherManager(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>> elementsQueue, java.util.function.Supplier<SplitReader<E,SplitT>> splitReaderFactory, java.util.function.Consumer<Collection<String>> splitFinishedHook) Create a split fetcher manager.

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

Classes in org.apache.flink.connector.kafka.source.reader that implement SplitReader

Modifier and Type	Class and Description
class	KafkaPartitionSplitReader A SplitReader implementation that reads records from Kafka partitions.

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

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

Constructor and Description

KafkaSourceFetcherManager(FutureCompletingBlockingQueue<RecordsWithSplitIds<org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]>>> elementsQueue, java.util.function.Supplier<SplitReader<org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]>,KafkaPartitionSplit>> splitReaderSupplier, java.util.function.Consumer<Collection<String>> splitFinishedHook) Creates a new SplitFetcherManager with a single I/O threads.

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

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

Constructor and Description
PulsarFetcherManagerBase(FutureCompletingBlockingQueue<RecordsWithSplitIds<PulsarMessage<T>>> elementsQueue, java.util.function.Supplier<SplitReader<PulsarMessage<T>,PulsarPartitionSplit>> splitReaderSupplier) Creates a new SplitFetcherManager with multiple I/O threads.
PulsarOrderedFetcherManager(FutureCompletingBlockingQueue<RecordsWithSplitIds<PulsarMessage<T>>> elementsQueue, java.util.function.Supplier<SplitReader<PulsarMessage<T>,PulsarPartitionSplit>> splitReaderSupplier)
PulsarUnorderedFetcherManager(FutureCompletingBlockingQueue<RecordsWithSplitIds<PulsarMessage<T>>> elementsQueue, java.util.function.Supplier<SplitReader<PulsarMessage<T>,PulsarPartitionSplit>> splitReaderSupplier)

Uses of SplitReader in org.apache.flink.connector.pulsar.source.reader.split

Classes in org.apache.flink.connector.pulsar.source.reader.split that implement SplitReader

Modifier and Type	Class and Description
class	PulsarOrderedPartitionSplitReader<OUT> The split reader a given PulsarPartitionSplit, it would be closed once the PulsarOrderedSourceReader is closed.
class	PulsarUnorderedPartitionSplitReader<OUT> The split reader a given PulsarPartitionSplit, it would be closed once the PulsarUnorderedSourceReader is closed.