Uses of Package
org.apache.flink.runtime.executiongraph

Packages that use org.apache.flink.runtime.executiongraph

Package	Description
org.apache.flink.runtime.accumulators
org.apache.flink.runtime.checkpoint
org.apache.flink.runtime.deployment
org.apache.flink.runtime.execution
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.executiongraph.failover
org.apache.flink.runtime.executiongraph.metrics	This package contains classes implementing various metrics for the job execution, based on the Execution Graph.
org.apache.flink.runtime.filecache
org.apache.flink.runtime.io.network
org.apache.flink.runtime.io.network.metrics
org.apache.flink.runtime.io.network.partition
org.apache.flink.runtime.io.network.partition.consumer
org.apache.flink.runtime.jobmanager.slots
org.apache.flink.runtime.jobmaster
org.apache.flink.runtime.jobmaster.factories
org.apache.flink.runtime.messages	This package contains the messages that are sent between Flink's distributed components to coordinate the distributed operations.
org.apache.flink.runtime.messages.checkpoint	This package contains the messages that are sent between JobMaster and TaskExecutor to coordinate the checkpoint snapshots of the distributed dataflow.
org.apache.flink.runtime.messages.webmonitor	This package contains the actor messages that are sent between the JobManager and components that are interested in the status of the JobManager.
org.apache.flink.runtime.metrics.groups
org.apache.flink.runtime.metrics.scope
org.apache.flink.runtime.minicluster
org.apache.flink.runtime.operators.coordination
org.apache.flink.runtime.query
org.apache.flink.runtime.rest.handler.job
org.apache.flink.runtime.rest.handler.job.checkpoints
org.apache.flink.runtime.rest.handler.job.metrics
org.apache.flink.runtime.rest.handler.util
org.apache.flink.runtime.rest.messages.job
org.apache.flink.runtime.scheduler
org.apache.flink.runtime.scheduler.adapter
org.apache.flink.runtime.scheduler.adaptive
org.apache.flink.runtime.scheduler.adaptive.allocator
org.apache.flink.runtime.scheduler.adaptivebatch
org.apache.flink.runtime.scheduler.exceptionhistory
org.apache.flink.runtime.scheduler.metrics
org.apache.flink.runtime.scheduler.slowtaskdetector
org.apache.flink.runtime.shuffle
org.apache.flink.runtime.state
org.apache.flink.runtime.taskexecutor
org.apache.flink.runtime.taskexecutor.rpc
org.apache.flink.runtime.taskexecutor.slot
org.apache.flink.runtime.taskmanager
org.apache.flink.runtime.webmonitor
org.apache.flink.runtime.webmonitor.history
org.apache.flink.runtime.webmonitor.stats
org.apache.flink.runtime.webmonitor.threadinfo
org.apache.flink.state.api.runtime

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.accumulators

Class and Description
ExecutionAttemptID Unique identifier for the attempt to execute a tasks.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.checkpoint

Class and Description
Execution A single execution of a vertex.
ExecutionAttemptID Unique identifier for the attempt to execute a tasks.
ExecutionJobVertex An ExecutionJobVertex is part of the ExecutionGraph, and the peer to the JobVertex.
ExecutionVertex The ExecutionVertex is a parallel subtask of the execution.
JobStatusListener Interface for observers that monitor the status of a job.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.deployment

Class and Description
Execution A single execution of a vertex.
ExecutionAttemptID Unique identifier for the attempt to execute a tasks.
IndexRange This class represents the range of index.
IntermediateResultPartition
JobInformation Container class for job information which is stored in the ExecutionGraph.
TaskInformation Container class for operator/task specific information which are stored at the ExecutionJobVertex.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.execution

Class and Description
ExecutionAttemptID Unique identifier for the attempt to execute a tasks.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.executiongraph

Class and Description
AccessExecution Common interface for the runtime Execution and ArchivedExecution.
AccessExecutionGraph Common interface for the runtime DefaultExecutionGraph and ArchivedExecutionGraph.
AccessExecutionJobVertex Common interface for the runtime ExecutionJobVertex and ArchivedExecutionJobVertex.
AccessExecutionVertex Common interface for the runtime ExecutionVertex and ArchivedExecutionVertex.
ArchivedExecution ArchivedExecution is a readonly representation of Execution.
ArchivedExecutionGraph An archived execution graph represents a serializable form of an ExecutionGraph.
ArchivedExecutionJobVertex
ArchivedExecutionVertex ArchivedExecutionVertex is a readonly representation of ExecutionVertex.
DefaultExecutionGraph Default implementation of the ExecutionGraph.
EdgeManager Class that manages all the connections between tasks.
ErrorInfo Simple container to hold an exception and the corresponding timestamp.
Execution A single execution of a vertex.
ExecutionAttemptID Unique identifier for the attempt to execute a tasks.
ExecutionDeploymentListener A listener that is called when the deployment of an execution has been started/completed.
ExecutionGraph The execution graph is the central data structure that coordinates the distributed execution of a data flow.
ExecutionGraphID A class for statistically unique execution graph IDs.
ExecutionHistory This class hosts the historical executions of an ExecutionVertex in a LinkedHashMap with a size bound.
ExecutionJobVertex An ExecutionJobVertex is part of the ExecutionGraph, and the peer to the JobVertex.
ExecutionJobVertex.Factory Factory to create ExecutionJobVertex.
ExecutionStateUpdateListener A listener that is called when an execution switched to a new state.
ExecutionVertex The ExecutionVertex is a parallel subtask of the execution.
ExecutionVertexInputInfo This class describe the inputs(partitions and subpartitions that belong to the same intermediate result) information of an execution vertex.
IndexRange This class represents the range of index.
IntermediateResult
IntermediateResultInfo
IntermediateResultPartition
InternalExecutionGraphAccessor This interface encapsulates all methods needed by ExecutionJobVertex / ExecutionVertices / Execution from the DefaultExecutionGraph.
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.
JobStatusListener Interface for observers that monitor the status of a job.
JobStatusProvider Interface for querying the state of a job and the timestamps of state transitions.
JobVertexInputInfo This class describe how a job vertex consume an input(intermediate result).
MarkPartitionFinishedStrategy This strategy is used to decide whether partition needs to be marked as finished.
MutableVertexAttemptNumberStore Mutability extension to the VertexAttemptNumberStore.
NoOpExecutionDeploymentListener No-op implementation of ExecutionDeploymentListener.
ResultPartitionBytes This class represents a snapshot of the result partition bytes metrics.
SubtaskAttemptNumberStore Contains the attempt number per subtask.
TaskExecutionStateTransition Wraps TaskExecutionState, along with actions to take if it is FAILED state.
TaskInformation Container class for operator/task specific information which are stored at the ExecutionJobVertex.
VertexAttemptNumberStore Contains the attempt numbers per vertex.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.executiongraph.failover

Class and Description
Execution A single execution of a vertex.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.executiongraph.metrics

Class and Description
JobStatusProvider Interface for querying the state of a job and the timestamps of state transitions.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.filecache

Class and Description
ExecutionAttemptID Unique identifier for the attempt to execute a tasks.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.io.network

Class and Description
ExecutionAttemptID Unique identifier for the attempt to execute a tasks.
PartitionInfo Contains information where to find a partition.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.io.network.metrics

Class and Description
ResultPartitionBytes This class represents a snapshot of the result partition bytes metrics.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.io.network.partition

Class and Description
ExecutionAttemptID Unique identifier for the attempt to execute a tasks.
IndexRange This class represents the range of index.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.io.network.partition.consumer

Class and Description
ExecutionAttemptID Unique identifier for the attempt to execute a tasks.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.jobmanager.slots

Class and Description
ExecutionAttemptID Unique identifier for the attempt to execute a tasks.
PartitionInfo Contains information where to find a partition.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.jobmaster

Class and Description
AccessExecutionGraph Common interface for the runtime DefaultExecutionGraph and ArchivedExecutionGraph.
ArchivedExecutionGraph An archived execution graph represents a serializable form of an ExecutionGraph.
ExecutionAttemptID Unique identifier for the attempt to execute a tasks.
ExecutionDeploymentListener A listener that is called when the deployment of an execution has been started/completed.
JobStatusListener Interface for observers that monitor the status of a job.
PartitionInfo Contains information where to find a partition.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.jobmaster.factories

Class and Description
ArchivedExecutionGraph An archived execution graph represents a serializable form of an ExecutionGraph.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.messages

Class and Description
ExecutionAttemptID Unique identifier for the attempt to execute a tasks.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.messages.checkpoint

Class and Description
ExecutionAttemptID Unique identifier for the attempt to execute a tasks.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.messages.webmonitor

Class and Description
AccessExecutionGraph Common interface for the runtime DefaultExecutionGraph and ArchivedExecutionGraph.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.metrics.groups

Class and Description
ExecutionAttemptID Unique identifier for the attempt to execute a tasks.
IOMetrics An instance of this class represents a snapshot of the io-related metrics of a single task.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.metrics.scope

Class and Description
ExecutionAttemptID Unique identifier for the attempt to execute a tasks.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.minicluster

Class and Description
AccessExecutionGraph Common interface for the runtime DefaultExecutionGraph and ArchivedExecutionGraph.
ArchivedExecutionGraph An archived execution graph represents a serializable form of an ExecutionGraph.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.operators.coordination

Class and Description
ExecutionAttemptID Unique identifier for the attempt to execute a tasks.
ExecutionJobVertex An ExecutionJobVertex is part of the ExecutionGraph, and the peer to the JobVertex.
TaskInformation Container class for operator/task specific information which are stored at the ExecutionJobVertex.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.query

Class and Description
ExecutionJobVertex An ExecutionJobVertex is part of the ExecutionGraph, and the peer to the JobVertex.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.rest.handler.job

Class and Description
AccessExecution Common interface for the runtime Execution and ArchivedExecution.
AccessExecutionGraph Common interface for the runtime DefaultExecutionGraph and ArchivedExecutionGraph.
AccessExecutionJobVertex Common interface for the runtime ExecutionJobVertex and ArchivedExecutionJobVertex.
AccessExecutionVertex Common interface for the runtime ExecutionVertex and ArchivedExecutionVertex.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.rest.handler.job.checkpoints

Class and Description
AccessExecutionGraph Common interface for the runtime DefaultExecutionGraph and ArchivedExecutionGraph.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.rest.handler.job.metrics

Class and Description
AccessExecutionJobVertex Common interface for the runtime ExecutionJobVertex and ArchivedExecutionJobVertex.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.rest.handler.util

Class and Description
AccessExecution Common interface for the runtime Execution and ArchivedExecution.
IOMetrics An instance of this class represents a snapshot of the io-related metrics of a single task.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.rest.messages.job

Class and Description
AccessExecution Common interface for the runtime Execution and ArchivedExecution.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.scheduler

Class and Description
ArchivedExecutionGraph An archived execution graph represents a serializable form of an ExecutionGraph.
Execution A single execution of a vertex.
ExecutionAttemptID Unique identifier for the attempt to execute a tasks.
ExecutionGraph The execution graph is the central data structure that coordinates the distributed execution of a data flow.
ExecutionJobVertex An ExecutionJobVertex is part of the ExecutionGraph, and the peer to the JobVertex.
ExecutionJobVertex.Factory Factory to create ExecutionJobVertex.
ExecutionStateUpdateListener A listener that is called when an execution switched to a new state.
ExecutionVertex The ExecutionVertex is a parallel subtask of the execution.
IOMetrics An instance of this class represents a snapshot of the io-related metrics of a single task.
JobStatusListener Interface for observers that monitor the status of a job.
JobStatusProvider Interface for querying the state of a job and the timestamps of state transitions.
MarkPartitionFinishedStrategy This strategy is used to decide whether partition needs to be marked as finished.
TaskExecutionStateTransition Wraps TaskExecutionState, along with actions to take if it is FAILED state.
VertexAttemptNumberStore Contains the attempt numbers per vertex.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.scheduler.adapter

Class and Description
DefaultExecutionGraph Default implementation of the ExecutionGraph.
EdgeManager Class that manages all the connections between tasks.
ExecutionJobVertex An ExecutionJobVertex is part of the ExecutionGraph, and the peer to the JobVertex.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.scheduler.adaptive

Class and Description
ArchivedExecutionGraph An archived execution graph represents a serializable form of an ExecutionGraph.
ExecutionAttemptID Unique identifier for the attempt to execute a tasks.
ExecutionGraph The execution graph is the central data structure that coordinates the distributed execution of a data flow.
JobStatusListener Interface for observers that monitor the status of a job.
TaskExecutionStateTransition Wraps TaskExecutionState, along with actions to take if it is FAILED state.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.scheduler.adaptive.allocator

Class and Description
ExecutionGraph The execution graph is the central data structure that coordinates the distributed execution of a data flow.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.scheduler.adaptivebatch

Class and Description
Execution A single execution of a vertex.
ExecutionAttemptID Unique identifier for the attempt to execute a tasks.
IndexRange This class represents the range of index.
IntermediateResultInfo
IOMetrics An instance of this class represents a snapshot of the io-related metrics of a single task.
JobStatusListener Interface for observers that monitor the status of a job.
MarkPartitionFinishedStrategy This strategy is used to decide whether partition needs to be marked as finished.
ParallelismAndInputInfos The parallelism and JobVertexInputInfos of a job vertex .
ResultPartitionBytes This class represents a snapshot of the result partition bytes metrics.
SpeculativeExecutionVertex The ExecutionVertex which supports speculative execution.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.scheduler.exceptionhistory

Class and Description
AccessExecution Common interface for the runtime Execution and ArchivedExecution.
ErrorInfo Simple container to hold an exception and the corresponding timestamp.
Execution A single execution of a vertex.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.scheduler.metrics

Class and Description
ExecutionAttemptID Unique identifier for the attempt to execute a tasks.
ExecutionStateUpdateListener A listener that is called when an execution switched to a new state.
JobStatusListener Interface for observers that monitor the status of a job.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.scheduler.slowtaskdetector

Class and Description
ExecutionAttemptID Unique identifier for the attempt to execute a tasks.
ExecutionGraph The execution graph is the central data structure that coordinates the distributed execution of a data flow.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.shuffle

Class and Description
ExecutionAttemptID Unique identifier for the attempt to execute a tasks.
IntermediateResultPartition
PartitionInfo Contains information where to find a partition.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.state

Class and Description
ExecutionAttemptID Unique identifier for the attempt to execute a tasks.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.taskexecutor

Class and Description
ExecutionAttemptID Unique identifier for the attempt to execute a tasks.
JobInformation Container class for job information which is stored in the ExecutionGraph.
PartitionInfo Contains information where to find a partition.
TaskInformation Container class for operator/task specific information which are stored at the ExecutionJobVertex.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.taskexecutor.rpc

Class and Description
ExecutionAttemptID Unique identifier for the attempt to execute a tasks.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.taskexecutor.slot

Class and Description
ExecutionAttemptID Unique identifier for the attempt to execute a tasks.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.taskmanager

Class and Description
ExecutionAttemptID Unique identifier for the attempt to execute a tasks.
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.
TaskInformation Container class for operator/task specific information which are stored at the ExecutionJobVertex.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.webmonitor

Class and Description
ArchivedExecutionGraph An archived execution graph represents a serializable form of an ExecutionGraph.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.webmonitor.history

Class and Description
AccessExecutionGraph Common interface for the runtime DefaultExecutionGraph and ArchivedExecutionGraph.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.webmonitor.stats

Class and Description
AccessExecutionJobVertex Common interface for the runtime ExecutionJobVertex and ArchivedExecutionJobVertex.
ExecutionAttemptID Unique identifier for the attempt to execute a tasks.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.runtime.webmonitor.threadinfo

Class and Description
AccessExecutionJobVertex Common interface for the runtime ExecutionJobVertex and ArchivedExecutionJobVertex.
ExecutionAttemptID Unique identifier for the attempt to execute a tasks.

Classes in org.apache.flink.runtime.executiongraph used by org.apache.flink.state.api.runtime

Class and Description
ExecutionAttemptID Unique identifier for the attempt to execute a tasks.