Package org.apache.flink.runtime.jobgraph.tasks

Interface Summary

Interface	Description
CheckpointCommittingOperator
CheckpointedOperator	This interface must be implemented by invokable operators (subclasses of AbstractInvokable that participate in state checkpoints.
InputSplitProvider	An input split provider can be successively queried to provide a series of InputSplit objects a task is supposed to consume in the course of its execution.
OperatorStateCarrier<T extends StateHandle<?>>	This interface must be implemented by any invokable that has recoverable state.

Class Summary

Class	Description
AbstractInvokable	This is the abstract base class for every task that can be executed ba a TaskManager.
InputSplitIterator<T extends org.apache.flink.core.io.InputSplit>	The input split iterator allows a task to iterate over all input splits it is supposed to consume.
JobSnapshottingSettings	The JobSnapshottingSettings are attached to a JobGraph and describe the settings for the asynchronous snapshotting of the JobGraph, such as interval, and which vertices need to participate.