Uses of Class
org.apache.flink.runtime.executiongraph.ExecutionAttemptID

Packages that use ExecutionAttemptID

Package	Description
org.apache.flink.runtime.deployment
org.apache.flink.runtime.execution.librarycache
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.io.network.partition
org.apache.flink.runtime.profiling
org.apache.flink.runtime.profiling.impl
org.apache.flink.runtime.profiling.impl.types
org.apache.flink.runtime.profiling.types
org.apache.flink.runtime.taskmanager

Uses of ExecutionAttemptID in org.apache.flink.runtime.deployment

Methods in org.apache.flink.runtime.deployment that return ExecutionAttemptID

Modifier and Type	Method and Description
ExecutionAttemptID	TaskDeploymentDescriptor.getExecutionId()

Constructors in org.apache.flink.runtime.deployment with parameters of type ExecutionAttemptID

Constructor and Description
TaskDeploymentDescriptor(JobID jobID, JobVertexID vertexID, ExecutionAttemptID executionId, String taskName, int indexInSubtaskGroup, int numberOfSubtasks, Configuration jobConfiguration, Configuration taskConfiguration, String invokableClassName, List<ResultPartitionDeploymentDescriptor> producedPartitions, List<InputGateDeploymentDescriptor> inputGates, List<BlobKey> requiredJarFiles, int targetSlotNumber) Constructs a task deployment descriptor.
TaskDeploymentDescriptor(JobID jobID, JobVertexID vertexID, ExecutionAttemptID executionId, String taskName, int indexInSubtaskGroup, int numberOfSubtasks, Configuration jobConfiguration, Configuration taskConfiguration, String invokableClassName, List<ResultPartitionDeploymentDescriptor> producedPartitions, List<InputGateDeploymentDescriptor> inputGates, List<BlobKey> requiredJarFiles, int targetSlotNumber, StateHandle operatorStates)

Uses of ExecutionAttemptID in org.apache.flink.runtime.execution.librarycache

Methods in org.apache.flink.runtime.execution.librarycache with parameters of type ExecutionAttemptID

Modifier and Type	Method and Description
void	LibraryCacheManager.registerTask(JobID id, ExecutionAttemptID execution, Collection<BlobKey> requiredJarFiles) Registers a job task execution with its required jar files.
void	FallbackLibraryCacheManager.registerTask(JobID id, ExecutionAttemptID execution, Collection<BlobKey> requiredJarFiles)
void	BlobLibraryCacheManager.registerTask(JobID jobId, ExecutionAttemptID task, Collection<BlobKey> requiredJarFiles)
void	LibraryCacheManager.unregisterTask(JobID id, ExecutionAttemptID execution) Unregisters a job from the library cache manager.
void	FallbackLibraryCacheManager.unregisterTask(JobID id, ExecutionAttemptID execution)
void	BlobLibraryCacheManager.unregisterTask(JobID jobId, ExecutionAttemptID task)

Uses of ExecutionAttemptID in org.apache.flink.runtime.executiongraph

Methods in org.apache.flink.runtime.executiongraph that return ExecutionAttemptID

Modifier and Type	Method and Description
static ExecutionAttemptID	ExecutionAttemptID.fromByteBuf(io.netty.buffer.ByteBuf buf)
ExecutionAttemptID	Execution.getAttemptId()

Methods in org.apache.flink.runtime.executiongraph that return types with arguments of type ExecutionAttemptID

Modifier and Type	Method and Description
Map<ExecutionAttemptID,Execution>	ExecutionGraph.getRegisteredExecutions()

Uses of ExecutionAttemptID in org.apache.flink.runtime.io.network.partition

Fields in org.apache.flink.runtime.io.network.partition with type parameters of type ExecutionAttemptID

Modifier and Type	Field and Description
com.google.common.collect.Table<ExecutionAttemptID,IntermediateResultPartitionID,ResultPartition>	ResultPartitionManager.registeredPartitions

Methods in org.apache.flink.runtime.io.network.partition that return ExecutionAttemptID

Modifier and Type	Method and Description
ExecutionAttemptID	ResultPartitionID.getProducerId()

Methods in org.apache.flink.runtime.io.network.partition with parameters of type ExecutionAttemptID

Modifier and Type	Method and Description
void	ResultPartitionManager.releasePartitionsProducedBy(ExecutionAttemptID executionId)

Constructors in org.apache.flink.runtime.io.network.partition with parameters of type ExecutionAttemptID

Constructor and Description
ResultPartitionID(IntermediateResultPartitionID partitionId, ExecutionAttemptID producerId)

Uses of ExecutionAttemptID in org.apache.flink.runtime.profiling

Methods in org.apache.flink.runtime.profiling with parameters of type ExecutionAttemptID

Modifier and Type	Method and Description
void	TaskManagerProfiler.unregisterTask(ExecutionAttemptID id) Unregisters all previously registered Task objects for the vertex identified by the given ID.

Uses of ExecutionAttemptID in org.apache.flink.runtime.profiling.impl

Constructors in org.apache.flink.runtime.profiling.impl with parameters of type ExecutionAttemptID

Constructor and Description
EnvironmentThreadSet(ThreadMXBean tmx, Thread mainThread, JobVertexID vertexId, int subtask, ExecutionAttemptID executionId)

Uses of ExecutionAttemptID in org.apache.flink.runtime.profiling.impl.types

Methods in org.apache.flink.runtime.profiling.impl.types that return ExecutionAttemptID

Modifier and Type	Method and Description
ExecutionAttemptID	InternalExecutionVertexProfilingData.getExecutionAttemptId()

Constructors in org.apache.flink.runtime.profiling.impl.types with parameters of type ExecutionAttemptID

Constructor and Description
InternalExecutionVertexProfilingData(JobID jobId, JobVertexID vertexId, int subtask, ExecutionAttemptID executionId)
InternalExecutionVertexThreadProfilingData(JobID jobID, JobVertexID vertexId, int subtask, ExecutionAttemptID executionId, int profilingInterval, int userTime, int systemTime, int blockedTime, int waitedTime)

Uses of ExecutionAttemptID in org.apache.flink.runtime.profiling.types

Methods in org.apache.flink.runtime.profiling.types that return ExecutionAttemptID

Modifier and Type	Method and Description
ExecutionAttemptID	VertexProfilingEvent.getExecutionId()

Constructors in org.apache.flink.runtime.profiling.types with parameters of type ExecutionAttemptID

Constructor and Description
ThreadProfilingEvent(int userTime, int systemTime, int blockedTime, int waitedTime, JobVertexID vertexId, int subtask, ExecutionAttemptID executionId, int profilingInterval, JobID jobID, long timestamp, long profilingTimestamp)
VertexProfilingEvent(JobVertexID vertexId, int subtask, ExecutionAttemptID executionId, int profilingInterval, JobID jobID, long timestamp, long profilingTimestamp)

Uses of ExecutionAttemptID in org.apache.flink.runtime.taskmanager

Methods in org.apache.flink.runtime.taskmanager that return ExecutionAttemptID

Modifier and Type	Method and Description
ExecutionAttemptID	Task.getExecutionId() Gets the ID of the execution attempt.
ExecutionAttemptID	TaskExecutionState.getID() Returns the ID of the task this result belongs to

Constructors in org.apache.flink.runtime.taskmanager with parameters of type ExecutionAttemptID

Constructor and Description
Task(JobID jobId, JobVertexID vertexId, int taskIndex, int parallelism, ExecutionAttemptID executionId, String taskName, akka.actor.ActorRef taskManager)
TaskExecutionState(JobID jobID, ExecutionAttemptID executionId, ExecutionState executionState) Creates a new task execution state update, with no attached exception.
TaskExecutionState(JobID jobID, ExecutionAttemptID executionId, ExecutionState executionState, Throwable error) Creates a new task execution state update, with an attached exception.
TaskInputSplitProvider(akka.actor.ActorRef jobManager, JobID jobId, JobVertexID vertexId, ExecutionAttemptID executionID, ClassLoader userCodeClassLoader, akka.util.Timeout timeout)