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.api.connector.source.util.ratelimit

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

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

Modifier and Type	Interface	Description
interface	ExternallyInducedSourceReader<T,SplitT extends SourceSplit>	Sources that implement this interface delay checkpoints when receiving a trigger message from the checkpoint coordinator to the point 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	Description
SourceReader<T,SplitT>	SourceReaderFactory.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	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	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.
class	IteratorSourceReaderBase<E,O,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.api.connector.source.util.ratelimit

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

Modifier and Type	Class	Description
class	RateLimitedSourceReader<E,SplitT extends SourceSplit>	Wraps the actual SourceReader and rate limits its data emission.

Constructors in org.apache.flink.api.connector.source.util.ratelimit with parameters of type SourceReader

Constructor	Description
RateLimitedSourceReader(SourceReader<E,SplitT> sourceReader, RateLimiter rateLimiter)	Instantiates a new rate-limited source reader.