public static class TaskMessages.PartitionState extends Object implements TaskMessages.TaskMessage, RequiresLeaderSessionID, scala.Product, scala.Serializable
RequestPartitionState
with the state of the respective partition.Constructor and Description |
---|
PartitionState(ExecutionAttemptID taskExecutionId,
IntermediateDataSetID taskResultId,
IntermediateResultPartitionID partitionId,
ExecutionState state) |
Modifier and Type | Method and Description |
---|---|
IntermediateResultPartitionID |
partitionId() |
ExecutionState |
state() |
ExecutionAttemptID |
taskExecutionId() |
IntermediateDataSetID |
taskResultId() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public PartitionState(ExecutionAttemptID taskExecutionId, IntermediateDataSetID taskResultId, IntermediateResultPartitionID partitionId, ExecutionState state)
public ExecutionAttemptID taskExecutionId()
public IntermediateDataSetID taskResultId()
public IntermediateResultPartitionID partitionId()
public ExecutionState state()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.