|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.
The interface provided by the Flink runtime to the
|Source<T,SplitT extends SourceSplit,EnumChkT>||
The interface for Source.
An base class for the events passed between the SourceReaders and Enumerators.
|SourceReader<T,SplitT extends SourceSplit>||
The interface for a source reader which is responsible for reading the records from the source splits assigned by
The interface that exposes some context from runtime to the
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
|SplitEnumeratorContext<SplitT extends SourceSplit>||
A context class for the
A container class hosting the information of a
|SplitsAssignment<SplitT extends SourceSplit>||
A class containing the splits assignment to the source readers.
The boundedness of a stream.
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.