T- The type of records produced by the source.
SplitT- The type of splits handled by the source.
@PublicEvolving public interface ExternallyInducedSourceReader<T,SplitT extends SourceSplit> extends SourceReader<T,SplitT>
The ExternallyInducedSourceReader tells the Flink runtime that a checkpoint needs to be made by returning a checkpointId when shouldTriggerCheckpoint() is invoked.
The implementations typically works together with the SplitEnumerator which informs the external system to trigger a checkpoint.
|Modifier and Type||Method and Description|
A method that informs the Flink runtime whether a checkpoint should be triggered on this Source.
addSplits, handleSourceEvents, isAvailable, notifyCheckpointAborted, notifyCheckpointComplete, notifyNoMoreSplits, pollNext, snapshotState, start
If a CheckpointId is returned, a checkpoint will be triggered on this source reader. Otherwise, Flink runtime will continue to process the records.
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.