Package org.apache.flink.runtime.executiongraph

Interface Summary

Interface	Description
AccessExecution	Common interface for the runtime Execution and {@link ArchivedExecution}.
AccessExecutionGraph	Common interface for the runtime ExecutionGraph and ArchivedExecutionGraph.
AccessExecutionJobVertex	Common interface for the runtime ExecutionJobVertex and ArchivedExecutionJobVertex.
AccessExecutionVertex	Common interface for the runtime ExecutionVertex and ArchivedExecutionVertex.
ExecutionStatusListener	Interface for observers that monitor the status of individual task executions.
JobStatusListener	Interface for observers that monitor the status of a job.

Class Summary

Class	Description
ArchivedExecution
ArchivedExecutionGraph
ArchivedExecutionJobVertex
ArchivedExecutionVertex
ErrorInfo	Simple container to hold an exception and the corresponding timestamp.
Execution	A single execution of a vertex.
ExecutionAndAllocationFuture	A pair of an Execution together with an allocation future.
ExecutionAttemptID	Unique identifier for the attempt to execute a tasks.
ExecutionEdge
ExecutionGraph	The execution graph is the central data structure that coordinates the distributed execution of a data flow.
ExecutionGraphBuilder	Utility class to encapsulate the logic of building an ExecutionGraph from a JobGraph.
ExecutionJobVertex	An ExecutionJobVertex is part of the ExecutionGraph, and the peer to the JobVertex.
ExecutionVertex	The ExecutionVertex is a parallel subtask of the execution.
IntermediateResult
IntermediateResultPartition
IOMetrics	An instance of this class represents a snapshot of the io-related metrics of a single task.
JobInformation	Container class for job information which is stored in the ExecutionGraph.
PartitionInfo	Contains information where to find a partition.
StatusListenerMessenger	A JobStatusListener and ExecutionStatusListener that sends an actor message for each status change.
TaskInformation	Container class for operator/task specific information which are stored at the ExecutionJobVertex.

Exception Summary

Exception	Description
ExecutionGraphException	Base class for exceptions occurring in the ExecutionGraph.
GlobalModVersionMismatch	An exception that indicates a mismatch between the expected global modification version of the execution graph, and the actual modification version.
IllegalExecutionStateException	A special IllegalStateException indicating a mismatch in the expected and actual ExecutionState of an Execution.