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

Packages that use ExecutionAttemptID

Package	Description
org.apache.flink.runtime.checkpoint
org.apache.flink.runtime.deployment
org.apache.flink.runtime.execution
org.apache.flink.runtime.execution.librarycache
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.io.network.netty
org.apache.flink.runtime.io.network.partition
org.apache.flink.runtime.io.network.partition.consumer
org.apache.flink.runtime.messages.checkpoint	This package contains the messages that are sent between JobManager and TaskManager to coordinate the checkpoint snapshots of the distributed dataflow.
org.apache.flink.runtime.taskmanager

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

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

Modifier and Type	Method and Description
boolean	PendingCheckpoint.acknowledgeTask(ExecutionAttemptID attemptID, SerializedValue<StateHandle<?>> state)

Constructor parameters in org.apache.flink.runtime.checkpoint with type arguments of type ExecutionAttemptID

Constructor and Description
PendingCheckpoint(org.apache.flink.api.common.JobID jobId, long checkpointId, long checkpointTimestamp, Map<ExecutionAttemptID,ExecutionVertex> verticesToConfirm)

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(org.apache.flink.api.common.JobID jobID, JobVertexID vertexID, ExecutionAttemptID executionId, String taskName, int indexInSubtaskGroup, int numberOfSubtasks, org.apache.flink.configuration.Configuration jobConfiguration, org.apache.flink.configuration.Configuration taskConfiguration, String invokableClassName, List<ResultPartitionDeploymentDescriptor> producedPartitions, List<InputGateDeploymentDescriptor> inputGates, List<BlobKey> requiredJarFiles, int targetSlotNumber)
TaskDeploymentDescriptor(org.apache.flink.api.common.JobID jobID, JobVertexID vertexID, ExecutionAttemptID executionId, String taskName, int indexInSubtaskGroup, int numberOfSubtasks, org.apache.flink.configuration.Configuration jobConfiguration, org.apache.flink.configuration.Configuration taskConfiguration, String invokableClassName, List<ResultPartitionDeploymentDescriptor> producedPartitions, List<InputGateDeploymentDescriptor> inputGates, List<BlobKey> requiredJarFiles, int targetSlotNumber, SerializedValue<StateHandle<?>> operatorState) Constructs a task deployment descriptor.

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

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

Modifier and Type	Method and Description
ExecutionAttemptID	Environment.getExecutionId() Gets the ID of the task execution attempt.

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	BlobLibraryCacheManager.registerTask(org.apache.flink.api.common.JobID jobId, ExecutionAttemptID task, Collection<BlobKey> requiredJarFiles)
void	FallbackLibraryCacheManager.registerTask(org.apache.flink.api.common.JobID id, ExecutionAttemptID execution, Collection<BlobKey> requiredJarFiles)
void	LibraryCacheManager.registerTask(org.apache.flink.api.common.JobID id, ExecutionAttemptID execution, Collection<BlobKey> requiredJarFiles) Registers a job task execution with its required jar files.
void	BlobLibraryCacheManager.unregisterTask(org.apache.flink.api.common.JobID jobId, ExecutionAttemptID task)
void	FallbackLibraryCacheManager.unregisterTask(org.apache.flink.api.common.JobID id, ExecutionAttemptID execution)
void	LibraryCacheManager.unregisterTask(org.apache.flink.api.common.JobID id, ExecutionAttemptID execution) Unregisters a job from the library cache manager.

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()

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

Modifier and Type	Method and Description
void	ExecutionVertex.sendMessageToCurrentExecution(Serializable message, ExecutionAttemptID attemptID)

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

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

Modifier and Type	Method and Description
void	PartitionStateChecker.triggerPartitionStateCheck(org.apache.flink.api.common.JobID jobId, ExecutionAttemptID executionId, IntermediateDataSetID resultId, ResultPartitionID partitionId)

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)
void	ResultPartitionManager.releasePartitionsProducedBy(ExecutionAttemptID executionId, Throwable cause)

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.io.network.partition.consumer

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

Modifier and Type	Method and Description
static SingleInputGate	SingleInputGate.create(String owningTaskName, org.apache.flink.api.common.JobID jobId, ExecutionAttemptID executionId, InputGateDeploymentDescriptor igdd, NetworkEnvironment networkEnvironment) Creates an input gate and all of its input channels.

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

Constructor and Description
SingleInputGate(String owningTaskName, org.apache.flink.api.common.JobID jobId, ExecutionAttemptID executionId, IntermediateDataSetID consumedResultId, int consumedSubpartitionIndex, int numberOfInputChannels, PartitionStateChecker partitionStateChecker)

Uses of ExecutionAttemptID in org.apache.flink.runtime.messages.checkpoint

Methods in org.apache.flink.runtime.messages.checkpoint that return ExecutionAttemptID

Modifier and Type	Method and Description
ExecutionAttemptID	AbstractCheckpointMessage.getTaskExecutionId()

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

Constructor and Description
AbstractCheckpointMessage(org.apache.flink.api.common.JobID job, ExecutionAttemptID taskExecutionId, long checkpointId)
AcknowledgeCheckpoint(org.apache.flink.api.common.JobID job, ExecutionAttemptID taskExecutionId, long checkpointId)
AcknowledgeCheckpoint(org.apache.flink.api.common.JobID job, ExecutionAttemptID taskExecutionId, long checkpointId, SerializedValue<StateHandle<?>> state)
ConfirmCheckpoint(org.apache.flink.api.common.JobID job, ExecutionAttemptID taskExecutionId, long checkpointId, long timestamp)
TriggerCheckpoint(org.apache.flink.api.common.JobID job, ExecutionAttemptID taskExecutionId, long checkpointId, long timestamp)

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()
ExecutionAttemptID	RuntimeEnvironment.getExecutionId()
ExecutionAttemptID	TaskExecutionState.getID() Returns the ID of the task this result belongs to

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

Modifier and Type	Method and Description
static String	Task.getTaskNameWithSubtaskAndID(String name, int subtask, int numSubtasks, ExecutionAttemptID id)

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

Constructor and Description
RuntimeEnvironment(org.apache.flink.api.common.JobID jobId, JobVertexID jobVertexId, ExecutionAttemptID executionId, String taskName, String taskNameWithSubtasks, int subtaskIndex, int parallelism, org.apache.flink.configuration.Configuration jobConfiguration, org.apache.flink.configuration.Configuration taskConfiguration, ClassLoader userCodeClassLoader, MemoryManager memManager, IOManager ioManager, BroadcastVariableManager bcVarManager, InputSplitProvider splitProvider, Map<String,Future<org.apache.flink.core.fs.Path>> distCacheEntries, ResultPartitionWriter[] writers, InputGate[] inputGates, akka.actor.ActorRef jobManagerActor)
TaskExecutionState(org.apache.flink.api.common.JobID jobID, ExecutionAttemptID executionId, ExecutionState executionState) Creates a new task execution state update, with no attached exception.
TaskExecutionState(org.apache.flink.api.common.JobID jobID, ExecutionAttemptID executionId, ExecutionState executionState, Throwable error) Creates a new task execution state update, with an attached exception.
TaskInputSplitProvider(akka.actor.ActorRef jobManager, org.apache.flink.api.common.JobID jobId, JobVertexID vertexId, ExecutionAttemptID executionID, ClassLoader userCodeClassLoader, akka.util.Timeout timeout)