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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
int	getAttemptNumber() Returns the attempt number of the subtask
ExecutionAttemptID	getExecutionId()
int	getIndexInSubtaskGroup() Returns the task's index in the subtask group.
List<InputGateDeploymentDescriptor>	getInputGates()
String	getInvokableClassName() Returns the name of the class containing the task code to be executed.
Configuration	getJobConfiguration() Returns the configuration of the job the task belongs to.
JobID	getJobID() Returns the ID of the job the tasks belongs to.
int	getNumberOfSubtasks() Returns the current number of subtasks.
SerializedValue<StateHandle<?>>	getOperatorState()
List<ResultPartitionDeploymentDescriptor>	getProducedPartitions()
long	getRecoveryTimestamp()
List<URL>	getRequiredClasspaths()
List<BlobKey>	getRequiredJarFiles()
int	getTargetSlotNumber() Gets the number of the slot into which the task is to be deployed.
Configuration	getTaskConfiguration() Returns the task's configuration object.
TaskInfo	getTaskInfo() Returns the TaskInfo object for the subtask
String	getTaskName() Returns the task's name.
JobVertexID	getVertexID() Returns the task's execution vertex ID.
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,
                                JobVertexID vertexID,
                                ExecutionAttemptID executionId,
                                String taskName,
                                int indexInSubtaskGroup,
                                int numberOfSubtasks,
                                int attemptNumber,
                                Configuration jobConfiguration,
                                Configuration taskConfiguration,
                                String invokableClassName,
                                List<ResultPartitionDeploymentDescriptor> producedPartitions,
                                List<InputGateDeploymentDescriptor> inputGates,
                                List<BlobKey> requiredJarFiles,
                                List<URL> requiredClasspaths,
                                int targetSlotNumber,
                                SerializedValue<StateHandle<?>> operatorState,
                                long recoveryTimestamp)

Constructs a task deployment descriptor.

TaskDeploymentDescriptor

public TaskDeploymentDescriptor(JobID jobID,
                                JobVertexID vertexID,
                                ExecutionAttemptID executionId,
                                String taskName,
                                int indexInSubtaskGroup,
                                int numberOfSubtasks,
                                int attemptNumber,
                                Configuration jobConfiguration,
                                Configuration taskConfiguration,
                                String invokableClassName,
                                List<ResultPartitionDeploymentDescriptor> producedPartitions,
                                List<InputGateDeploymentDescriptor> inputGates,
                                List<BlobKey> requiredJarFiles,
                                List<URL> requiredClasspaths,
                                int targetSlotNumber)

Method Detail

getJobID

public JobID getJobID()

Returns the ID of the job the tasks belongs to.

getVertexID

public JobVertexID getVertexID()

Returns the task's execution vertex ID.

getExecutionId

public ExecutionAttemptID getExecutionId()

getTaskName

public String getTaskName()

Returns the task's name.

getIndexInSubtaskGroup

public int getIndexInSubtaskGroup()

Returns the task's index in the subtask group.

Returns:

the task's index in the subtask group

getNumberOfSubtasks

public int getNumberOfSubtasks()

Returns the current number of subtasks.

getAttemptNumber

public int getAttemptNumber()

Returns the attempt number of the subtask

getTaskInfo

public TaskInfo getTaskInfo()

Returns the TaskInfo object for 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.

getJobConfiguration

public Configuration getJobConfiguration()

Returns the configuration of the job the task belongs to.

getTaskConfiguration

public Configuration getTaskConfiguration()

Returns the task's configuration object.

getInvokableClassName

public String getInvokableClassName()

Returns the name of the class containing the task code to be executed.

getProducedPartitions

public List<ResultPartitionDeploymentDescriptor> getProducedPartitions()

getInputGates

public List<InputGateDeploymentDescriptor> getInputGates()

getRequiredJarFiles

public List<BlobKey> getRequiredJarFiles()

getRequiredClasspaths

public List<URL> getRequiredClasspaths()

toString

public String toString()

Overrides:

toString in class Object

getOperatorState

public SerializedValue<StateHandle<?>> getOperatorState()

getRecoveryTimestamp

public long getRecoveryTimestamp()