Package org.apache.flink.streaming.api.checkpoint

Interface Summary

Interface	Description
CheckpointedFunction	This is the core interface for stateful transformation functions, meaning functions that maintain state across individual stream records.
ExternallyInducedSource<T,CD>	Sources that implement this interface do not trigger checkpoints when receiving a trigger message from the checkpoint coordinator, but when their input data/events indicate that a checkpoint should be triggered.
ExternallyInducedSource.CheckpointTrigger	Through the CheckpointTrigger, the source function notifies the Flink source operator when to trigger the checkpoint.
ListCheckpointed<T extends Serializable>	Deprecated If you need to do non-keyed state snapshots of your operator, use CheckpointedFunction.
WithMasterCheckpointHook<E>	This interface can be implemented by streaming functions that need to trigger a "global action" on the master (in the checkpoint coordinator) as part of every checkpoint and restore operation.