Package org.apache.flink.runtime.jobgraph

Class Summary

Class	Description
InputOutputFormatContainer	A container for InputFormats and OutputFormats, along with their Configuration.
InputOutputFormatContainer.FormatUserCodeTable	Container for multiple wrappers containing InputFormat and OutputFormat code.
InputOutputFormatVertex	A task vertex that runs an initialization and a finalization on the master.
IntermediateDataSet	An intermediate data set is the data set produced by an operator - either a source or any intermediate operation.
IntermediateDataSetID	Id identifying IntermediateDataSet.
IntermediateResultPartitionID	Id identifying IntermediateResultPartition.
JobEdge	This class represent edges (communication channels) in a job graph.
JobGraph	The JobGraph represents a Flink dataflow program, at the low level that the JobManager accepts.
JobVertex	The base class for job vertexes.
JobVertexID	A class for statistically unique job vertex IDs.
OperatorID	A class for statistically unique operator IDs.
OperatorInstanceID	An ID for physical instance of the operator.
SavepointConfigOptions	The configuration options used when restoring from a savepoint.
SavepointRestoreSettings	Savepoint restore settings.

Enum Summary

Enum	Description
DistributionPattern	A distribution pattern determines, which sub tasks of a producing task are connected to which consuming sub tasks.
JobGraphUtils	Utilities for generating JobGraph.
ScheduleMode	The ScheduleMode decides how tasks of an execution graph are started.