public static class JobManagerMessages.RequestPartitionProducerState extends Object implements RequiresLeaderSessionID, scala.Product, scala.Serializable
param: jobId ID of the job the partition belongs to. param: intermediateDataSetId ID of the parent intermediate data set. param: resultPartitionId ID of the result partition to check. This identifies the producing execution and partition.
Constructor and Description |
---|
RequestPartitionProducerState(JobID jobId,
IntermediateDataSetID intermediateDataSetId,
ResultPartitionID resultPartitionId) |
Modifier and Type | Method and Description |
---|---|
IntermediateDataSetID |
intermediateDataSetId() |
JobID |
jobId() |
ResultPartitionID |
resultPartitionId() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public RequestPartitionProducerState(JobID jobId, IntermediateDataSetID intermediateDataSetId, ResultPartitionID resultPartitionId)
public JobID jobId()
public IntermediateDataSetID intermediateDataSetId()
public ResultPartitionID resultPartitionId()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.