Package org.apache.flink.api.connector.source

Interface Summary

Interface	Description
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.
ReaderOutput<T>	The interface provided by the Flink runtime to the SourceReader to emit records, and optionally watermarks, to downstream operators for message processing.
Source<T,SplitT extends SourceSplit,EnumChkT>	The interface for Source.
SourceEvent	An base class for the events passed between the SourceReaders and Enumerators.
SourceOutput<T>	The SourceOutput is the gateway for a SourceReader) to emit the produced records and watermarks.
SourceReader<T,SplitT extends SourceSplit>	The interface for a source reader which is responsible for reading the records from the source splits assigned by SplitEnumerator.
SourceReaderContext	The class that expose some context from runtime to the SourceReader.
SourceSplit	An interface for all the Split types to extend.
SplitEnumerator<SplitT extends SourceSplit,CheckpointT>	A interface of a split enumerator responsible for the followings: 1.
SplitEnumeratorContext<SplitT extends SourceSplit>	A context class for the SplitEnumerator.

Class Summary

Class	Description
ReaderInfo	A container class hosting the information of a SourceReader.
SplitsAssignment<SplitT extends SourceSplit>	A class containing the splits assignment to the source readers.

Enum Summary

Enum	Description
Boundedness	The boundedness of a stream.