public final class TaskDeploymentDescriptor extends Object implements Serializable
Constructor and Description |
---|
TaskDeploymentDescriptor(SerializedValue<JobInformation> serializedJobInformation,
SerializedValue<TaskInformation> serializedTaskInformation,
ExecutionAttemptID executionAttemptId,
AllocationID allocationId,
int subtaskIndex,
int attemptNumber,
int targetSlotNumber,
TaskStateHandles taskStateHandles,
Collection<ResultPartitionDeploymentDescriptor> resultPartitionDeploymentDescriptors,
Collection<InputGateDeploymentDescriptor> inputGateDeploymentDescriptors) |
Modifier and Type | Method and Description |
---|---|
AllocationID |
getAllocationId() |
int |
getAttemptNumber()
Returns the attempt number of the subtask
|
ExecutionAttemptID |
getExecutionAttemptId() |
Collection<InputGateDeploymentDescriptor> |
getInputGates() |
Collection<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.
|
TaskStateHandles |
getTaskStateHandles() |
String |
toString() |
public TaskDeploymentDescriptor(SerializedValue<JobInformation> serializedJobInformation, SerializedValue<TaskInformation> serializedTaskInformation, ExecutionAttemptID executionAttemptId, AllocationID allocationId, int subtaskIndex, int attemptNumber, int targetSlotNumber, TaskStateHandles taskStateHandles, Collection<ResultPartitionDeploymentDescriptor> resultPartitionDeploymentDescriptors, Collection<InputGateDeploymentDescriptor> inputGateDeploymentDescriptors)
public SerializedValue<JobInformation> getSerializedJobInformation()
public SerializedValue<TaskInformation> getSerializedTaskInformation()
public ExecutionAttemptID getExecutionAttemptId()
public int getSubtaskIndex()
public int getAttemptNumber()
public int getTargetSlotNumber()
public Collection<ResultPartitionDeploymentDescriptor> getProducedPartitions()
public Collection<InputGateDeploymentDescriptor> getInputGates()
public TaskStateHandles getTaskStateHandles()
public AllocationID getAllocationId()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.