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

Interface Summary

Interface	Description
RecordEmitter<E,T,SplitStateT>	Emit a record to the downstream.
RecordEvaluator<T>	An interface that evaluates whether a de-serialized record should trigger certain control-flow operations (e.g. end of stream).
RecordsWithSplitIds<E>	An interface for the elements passed from the fetchers to the source reader.

Class Summary

Class	Description
RecordsBySplits<E>	An implementation of RecordsWithSplitIds to host all the records by splits.
RecordsBySplits.Builder<E>	A utility builder to collect records in individual calls, rather than put a finished collection in the RecordsBySplits(Map, Set) constructor.
SingleThreadMultiplexSourceReaderBase<E,T,SplitT extends SourceSplit,SplitStateT>	A base for SourceReaders that read splits with one thread using one SplitReader.
SourceReaderBase<E,T,SplitT extends SourceSplit,SplitStateT>	An abstract implementation of SourceReader which provides some synchronization between the mail box main thread and the SourceReader internal threads.
SourceReaderOptions	The options that can be set for the SourceReaderBase.