org.apache.flink.runtime.deployment

Class TaskDeploymentDescriptor

java.lang.Object

org.apache.flink.runtime.deployment.TaskDeploymentDescriptor

All Implemented Interfaces:

Serializable

public final class TaskDeploymentDescriptor
extends Object
implements Serializable

A task deployment descriptor contains all the information necessary to deploy a task on a task manager.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TaskDeploymentDescriptor.MaybeOffloaded<T> Wrapper class for serialized values which may be offloaded to the BlobServer or not.
static class	TaskDeploymentDescriptor.NonOffloaded<T> A serialized value that is not offloaded to the BlobServer.
static class	TaskDeploymentDescriptor.Offloaded<T> Reference to a serialized value that was offloaded to the BlobServer.

Constructor Summary

Constructors

Constructor and Description

TaskDeploymentDescriptor(JobID jobId, TaskDeploymentDescriptor.MaybeOffloaded<JobInformation> serializedJobInformation, TaskDeploymentDescriptor.MaybeOffloaded<TaskInformation> serializedTaskInformation, ExecutionAttemptID executionAttemptId, AllocationID allocationId, int subtaskIndex, int attemptNumber, int targetSlotNumber, JobManagerTaskRestore taskRestore, List<ResultPartitionDeploymentDescriptor> resultPartitionDeploymentDescriptors, List<InputGateDeploymentDescriptor> inputGateDeploymentDescriptors)

Method Summary

Modifier and Type	Method and Description
AllocationID	getAllocationId()
int	getAttemptNumber() Returns the attempt number of the subtask.
ExecutionAttemptID	getExecutionAttemptId()
List<InputGateDeploymentDescriptor>	getInputGates()
JobID	getJobId() Returns the task's job ID.
List<ResultPartitionDeploymentDescriptor>	getProducedPartitions()
SerializedValue<JobInformation>	getSerializedJobInformation() Return the sub task's serialized job information.
SerializedValue<TaskInformation>	getSerializedTaskInformation() Return the sub task's serialized task information.
int	getSubtaskIndex() Returns the task's index in the subtask group.
int	getTargetSlotNumber() Gets the number of the slot into which the task is to be deployed.
JobManagerTaskRestore	getTaskRestore()
void	loadBigData(PermanentBlobService blobService) Loads externalized data from the BLOB store back to the object.
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

TaskDeploymentDescriptor

public TaskDeploymentDescriptor(JobID jobId,
                                TaskDeploymentDescriptor.MaybeOffloaded<JobInformation> serializedJobInformation,
                                TaskDeploymentDescriptor.MaybeOffloaded<TaskInformation> serializedTaskInformation,
                                ExecutionAttemptID executionAttemptId,
                                AllocationID allocationId,
                                int subtaskIndex,
                                int attemptNumber,
                                int targetSlotNumber,
                                @Nullable
                                JobManagerTaskRestore taskRestore,
                                List<ResultPartitionDeploymentDescriptor> resultPartitionDeploymentDescriptors,
                                List<InputGateDeploymentDescriptor> inputGateDeploymentDescriptors)

Method Detail

getSerializedJobInformation

public SerializedValue<JobInformation> getSerializedJobInformation()

Return the sub task's serialized job information.

Returns:

serialized job information (may throw IllegalStateException if loadBigData(PermanentBlobService) is not called beforehand).

Throws:

IllegalStateException - If job information is offloaded to BLOB store.

getSerializedTaskInformation

public SerializedValue<TaskInformation> getSerializedTaskInformation()

Return the sub task's serialized task information.

Returns:

serialized task information (may throw IllegalStateException if loadBigData(PermanentBlobService) is not called beforehand)).

Throws:

IllegalStateException - If job information is offloaded to BLOB store.

getJobId

public JobID getJobId()

Returns the task's job ID.

Returns:

the job ID this task belongs to

getExecutionAttemptId

public ExecutionAttemptID getExecutionAttemptId()

getSubtaskIndex

public int getSubtaskIndex()

Returns the task's index in the subtask group.

Returns:

the task's index in the subtask group

getAttemptNumber

public int getAttemptNumber()

Returns the attempt number of the subtask.

getTargetSlotNumber

public int getTargetSlotNumber()

Gets the number of the slot into which the task is to be deployed.

Returns:

The number of the target slot.

getProducedPartitions

public List<ResultPartitionDeploymentDescriptor> getProducedPartitions()

getInputGates

public List<InputGateDeploymentDescriptor> getInputGates()

getTaskRestore

@Nullable
public JobManagerTaskRestore getTaskRestore()

getAllocationId

public AllocationID getAllocationId()

loadBigData

public void loadBigData(@Nullable
                        PermanentBlobService blobService)
                 throws IOException,
                        ClassNotFoundException

Loads externalized data from the BLOB store back to the object.

Parameters:

blobService - the blob store to use (may be null if serializedJobInformation and serializedTaskInformation are non-null)

Throws:

IOException - during errors retrieving or reading the BLOBs

ClassNotFoundException - Class of a serialized object cannot be found.

toString

public String toString()

Overrides:

toString in class Object