org.apache.flink.runtime.jobgraph.tasks

Interface CheckpointedOperator

public interface CheckpointedOperator

This interface must be implemented by invokable operators (subclasses of AbstractInvokable that participate in state checkpoints.

Method Summary

Modifier and Type	Method and Description
void	triggerCheckpoint(long checkpointId, long timestamp) This method is either called directly and asynchronously by the checkpoint coordinator (in the case of functions that are directly notified - usually the data sources), or called synchronously when all incoming channels have reported a checkpoint barrier.

Method Detail

triggerCheckpoint

void triggerCheckpoint(long checkpointId,
                       long timestamp)
                throws Exception

This method is either called directly and asynchronously by the checkpoint coordinator (in the case of functions that are directly notified - usually the data sources), or called synchronously when all incoming channels have reported a checkpoint barrier.

Parameters:

checkpointId - The ID of the checkpoint, incrementing.

timestamp - The timestamp when the checkpoint was triggered at the JobManager.

Throws:

Exception