org.apache.flink.runtime.state

Interface CheckpointListener

All Known Implementing Classes:

FlinkKafkaConsumer08, FlinkKafkaConsumer081, FlinkKafkaConsumer082, FlinkKafkaConsumer09, FlinkKafkaConsumerBase, LazyDbValueState, MessageAcknowledgingSourceBase, MultipleIdsMessageAcknowledgingSourceBase, RMQSource, RollingSink

public interface CheckpointListener

This interface must be implemented by functions/operations that want to receive a commit notification once a checkpoint has been completely acknowledged by all participants.

Method Summary

Modifier and Type	Method and Description
void	notifyCheckpointComplete(long checkpointId) This method is called as a notification once a distributed checkpoint has been completed.

Method Detail

notifyCheckpointComplete

void notifyCheckpointComplete(long checkpointId)
                       throws Exception

This method is called as a notification once a distributed checkpoint has been completed. Note that any exception during this method will not cause the checkpoint to fail any more.

Parameters:

checkpointId - The ID of the checkpoint that has been completed.

Throws:

Exception