| DynamicFilteringInfo |
A decorative interface that indicates it holds the dynamic partition filtering data.
|
| DynamicParallelismInference |
Sources that implement this interface will dynamically infer the source’s parallelism when it is
unspecified.
|
| DynamicParallelismInference.Context |
A context that provides dynamic parallelism decision infos.
|
| 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> |
|
| SupportsHandleExecutionAttemptSourceEvent |
|
| SupportsIntermediateNoMoreSplits |
|