Uses of Interface
org.apache.flink.api.common.state.CheckpointListener

Packages that use CheckpointListener

Package	Description
org.apache.flink.api.common.state
org.apache.flink.api.connector.source
org.apache.flink.api.connector.source.lib.util
org.apache.flink.api.connector.source.util.ratelimit

Uses of CheckpointListener in org.apache.flink.api.common.state

Subinterfaces of CheckpointListener in org.apache.flink.api.common.state

Modifier and Type	Interface	Description
interface	InternalCheckpointListener	The internal checkpoint listener add another InternalCheckpointListener.notifyCheckpointSubsumed(long) interface for internal usage.

Uses of CheckpointListener in org.apache.flink.api.connector.source

Subinterfaces of CheckpointListener in org.apache.flink.api.connector.source

Modifier and Type	Interface	Description
interface	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.
interface	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.
interface	SplitEnumerator<SplitT extends SourceSplit,CheckpointT>	The interface for a split enumerator responsible for discovering the source splits, and assigning them to the SourceReader.

Uses of CheckpointListener in org.apache.flink.api.connector.source.lib.util

Classes in org.apache.flink.api.connector.source.lib.util that implement CheckpointListener

Modifier and Type	Class	Description
class	IteratorSourceEnumerator<SplitT extends IteratorSourceSplit<?,?>>	A SplitEnumerator for iterator sources.
class	IteratorSourceReader<E,IterT extends Iterator<E>,SplitT extends IteratorSourceSplit<E,IterT>>	A SourceReader that returns the values of an iterator, supplied via an IteratorSourceSplit.
class	IteratorSourceReaderBase<E,O,IterT extends Iterator<E>,SplitT extends IteratorSourceSplit<E,IterT>>	A SourceReader that returns the values of an iterator, supplied via an IteratorSourceSplit.

Uses of CheckpointListener in org.apache.flink.api.connector.source.util.ratelimit

Classes in org.apache.flink.api.connector.source.util.ratelimit that implement CheckpointListener

Modifier and Type	Class	Description
class	RateLimitedSourceReader<E,SplitT extends SourceSplit>	Wraps the actual SourceReader and rate limits its data emission.