Uses of Interface
org.apache.flink.api.connector.source.SourceReader

Packages that use SourceReader

Package	Description
org.apache.flink.api.connector.source
org.apache.flink.api.connector.source.lib
org.apache.flink.api.connector.source.lib.util
org.apache.flink.connector.base.source.reader
org.apache.flink.connector.file.src
org.apache.flink.connector.file.src.impl
org.apache.flink.connector.kafka.source
org.apache.flink.connector.kafka.source.reader
org.apache.flink.connector.testutils.source.reader
org.apache.flink.streaming.api.operators

Uses of SourceReader in org.apache.flink.api.connector.source

Subinterfaces of SourceReader in org.apache.flink.api.connector.source

Modifier and Type	Interface and Description
interface	ExternallyInducedSourceReader<T,SplitT extends SourceSplit> Sources that implement this interface do not trigger checkpoints when receiving a trigger message from the checkpoint coordinator, but when their input data/events indicate that a checkpoint should be triggered.

Methods in org.apache.flink.api.connector.source that return SourceReader

Modifier and Type	Method and Description
SourceReader<T,SplitT>	Source.createReader(SourceReaderContext readerContext) Creates a new reader to read data from the splits it gets assigned.

Uses of SourceReader in org.apache.flink.api.connector.source.lib

Methods in org.apache.flink.api.connector.source.lib that return SourceReader

Modifier and Type	Method and Description
SourceReader<Long,NumberSequenceSource.NumberSequenceSplit>	NumberSequenceSource.createReader(SourceReaderContext readerContext)

Uses of SourceReader in org.apache.flink.api.connector.source.lib.util

Classes in org.apache.flink.api.connector.source.lib.util that implement SourceReader

Modifier and Type	Class and Description
class	IteratorSourceReader<E,IterT extends Iterator<E>,SplitT extends IteratorSourceSplit<E,IterT>> A SourceReader that returns the values of an iterator, supplied via an IteratorSourceSplit.

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

Classes in org.apache.flink.connector.base.source.reader that implement SourceReader

Modifier and Type	Class and Description
class	SingleThreadMultiplexSourceReaderBase<E,T,SplitT extends SourceSplit,SplitStateT> A base for SourceReaders that read splits with one thread using one SplitReader.
class	SourceReaderBase<E,T,SplitT extends SourceSplit,SplitStateT> An abstract implementation of SourceReader which provides some sychronization between the mail box main thread and the SourceReader internal threads.

Uses of SourceReader in org.apache.flink.connector.file.src

Methods in org.apache.flink.connector.file.src that return SourceReader

Modifier and Type	Method and Description
SourceReader<T,SplitT>	AbstractFileSource.createReader(SourceReaderContext readerContext)

Uses of SourceReader in org.apache.flink.connector.file.src.impl

Classes in org.apache.flink.connector.file.src.impl that implement SourceReader

Modifier and Type	Class and Description
class	FileSourceReader<T,SplitT extends FileSourceSplit> A SourceReader that read records from FileSourceSplit.

Uses of SourceReader in org.apache.flink.connector.kafka.source

Methods in org.apache.flink.connector.kafka.source that return SourceReader

Modifier and Type	Method and Description
SourceReader<OUT,KafkaPartitionSplit>	KafkaSource.createReader(SourceReaderContext readerContext)

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

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

Modifier and Type	Class and Description
class	KafkaSourceReader<T> The source reader for Kafka partitions.

Uses of SourceReader in org.apache.flink.connector.testutils.source.reader

Methods in org.apache.flink.connector.testutils.source.reader that return SourceReader

Modifier and Type	Method and Description
protected abstract SourceReader<Integer,SplitT>	SourceReaderTestBase.createReader()

Uses of SourceReader in org.apache.flink.streaming.api.operators

Methods in org.apache.flink.streaming.api.operators that return SourceReader

Modifier and Type	Method and Description
SourceReader<OUT,SplitT>	SourceOperator.getSourceReader()

Constructor parameters in org.apache.flink.streaming.api.operators with type arguments of type SourceReader

Constructor and Description
SourceOperator(FunctionWithException<SourceReaderContext,SourceReader<OUT,SplitT>,Exception> readerFactory, OperatorEventGateway operatorEventGateway, SimpleVersionedSerializer<SplitT> splitSerializer, WatermarkStrategy<OUT> watermarkStrategy, ProcessingTimeService timeService, Configuration configuration, String localHostname, boolean emitProgressiveWatermarks)