Package org.apache.flink.runtime.jobgraph

Interface Summary

Interface	Description
JobVertex.FinalizeOnMasterContext	The context exposes some runtime infos for finalization.
JobVertex.InitializeOnMasterContext

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.
JobGraphBuilder	Builder for the JobGraph.
JobResourceRequirements	Information about the parallelism of job vertices.
JobResourceRequirements.Builder
JobVertex	The base class for job vertexes.
JobVertexID	A class for statistically unique job vertex IDs.
JobVertexResourceRequirements	Information about the parallelism of job vertices.
JobVertexResourceRequirements.Parallelism
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.
JobType	Enum to distinguish JobGraphs between batch and streaming, currently used by the scheduler.
RestoreMode	Defines how Flink should restore from a given savepoint or retained checkpoint.