public final class TaskDeploymentDescriptor extends Object implements Serializable
Constructor and Description |
---|
TaskDeploymentDescriptor(SerializedValue<JobInformation> serializedJobInformation,
SerializedValue<TaskInformation> serializedTaskInformation,
ExecutionAttemptID executionAttemptId,
int subtaskIndex,
int attemptNumber,
int targetSlotNumber,
SerializedValue<StateHandle<?>> operatorState,
Collection<ResultPartitionDeploymentDescriptor> resultPartitionDeploymentDescriptors,
Collection<InputGateDeploymentDescriptor> inputGateDeploymentDescriptors) |
Modifier and Type | Method and Description |
---|---|
int |
getAttemptNumber()
Returns the attempt number of the subtask
|
ExecutionAttemptID |
getExecutionAttemptId() |
Collection<InputGateDeploymentDescriptor> |
getInputGates() |
SerializedValue<StateHandle<?>> |
getOperatorState() |
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.
|
String |
toString() |
public TaskDeploymentDescriptor(SerializedValue<JobInformation> serializedJobInformation, SerializedValue<TaskInformation> serializedTaskInformation, ExecutionAttemptID executionAttemptId, int subtaskIndex, int attemptNumber, int targetSlotNumber, SerializedValue<StateHandle<?>> operatorState, 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 SerializedValue<StateHandle<?>> getOperatorState()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.