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 | Description |
---|---|
ArchivedExecution | |
ArchivedExecutionGraph |
An archived execution graph represents a serializable form of the
ExecutionGraph . |
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 | |
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 | 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 . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.