public static class JobManagerMessages.RequestPartitionState extends Object implements RequiresLeaderSessionID, scala.Product, scala.Serializable
The state of a partition is currently bound to the state of the producing execution.
Constructor and Description |
---|
RequestPartitionState(JobID jobId,
ResultPartitionID partitionId,
ExecutionAttemptID taskExecutionId,
IntermediateDataSetID taskResultId) |
Modifier and Type | Method and Description |
---|---|
JobID |
jobId() |
ResultPartitionID |
partitionId() |
ExecutionAttemptID |
taskExecutionId() |
IntermediateDataSetID |
taskResultId() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public RequestPartitionState(JobID jobId, ResultPartitionID partitionId, ExecutionAttemptID taskExecutionId, IntermediateDataSetID taskResultId)
public JobID jobId()
public ResultPartitionID partitionId()
public ExecutionAttemptID taskExecutionId()
public IntermediateDataSetID taskResultId()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.