org.apache.flink.streaming.api.checkpoint

Interface CheckpointedAsynchronously<T extends Serializable>

All Superinterfaces:

Checkpointed<T>

All Known Implementing Classes:

FlinkKafkaConsumer08, FlinkKafkaConsumer081, FlinkKafkaConsumer082, FlinkKafkaConsumer09, FlinkKafkaConsumerBase, FromElementsFunction

@PublicEvolving
public interface CheckpointedAsynchronously<T extends Serializable>
extends Checkpointed<T>

This interface marks a function/operator as asynchronously checkpointed. Similar to the Checkpointed interface, the function must produce a snapshot of its state. However, the function must be able to continue working and mutating its state without mutating the returned state snapshot.

Asynchronous checkpoints are desirable, because they allow the data streams at the point of the checkpointed function/operator to continue running while the checkpoint is in progress.

To be able to support asynchronous snapshots, the state returned by the Checkpointed.snapshotState(long, long) method is typically a copy or shadow copy of the actual state.

Method Summary

Methods inherited from interface org.apache.flink.streaming.api.checkpoint.Checkpointed

restoreState, snapshotState