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

Interface Summary

Interface	Description
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.
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 interface that exposes some context from runtime to the SourceReader.
SourceReaderFactory<T,SplitT extends SourceSplit>	A factory for creating source reader instances.
SourceSplit	An interface for all the Split types to extend.
SplitEnumerator<SplitT extends SourceSplit,CheckpointT>	The interface for a split enumerator responsible for discovering the source splits, and assigning them to the SourceReader.
SplitEnumeratorContext<SplitT extends SourceSplit>	A context class for the SplitEnumerator.
SupportsHandleExecutionAttemptSourceEvent	An decorative interface of SplitEnumerator which allows to handle SourceEvent sent from a specific execution attempt.
SupportsIntermediateNoMoreSplits	A decorative interface of SplitEnumeratorContext which allows to handle intermediate NoMoreSplits.

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.