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

Method Summary

Modifier and Type	Method and Description
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.
StateHandle	getOperatorStates()
List<ResultPartitionDeploymentDescriptor>	getProducedPartitions()
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.
String	getTaskName() Returns the task's name.
JobVertexID	getVertexID() Returns the task's execution vertex ID.
void	setOperatorState(StateHandle operatorStates)
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,
                                Configuration jobConfiguration,
                                Configuration taskConfiguration,
                                String invokableClassName,
                                List<ResultPartitionDeploymentDescriptor> producedPartitions,
                                List<InputGateDeploymentDescriptor> inputGates,
                                List<BlobKey> requiredJarFiles,
                                int targetSlotNumber)

Constructs a task deployment descriptor.

TaskDeploymentDescriptor

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

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.

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

toString

public String toString()

Overrides:

toString in class Object

setOperatorState

public void setOperatorState(StateHandle operatorStates)

getOperatorStates

public StateHandle getOperatorStates()