public class ResultPartitionDeploymentDescriptor extends Object implements Serializable
ResultPartition
,
Serialized FormConstructor and Description |
---|
ResultPartitionDeploymentDescriptor(PartitionDescriptor partitionDescriptor,
ShuffleDescriptor shuffleDescriptor,
int maxParallelism,
boolean notifyPartitionDataAvailable) |
Modifier and Type | Method and Description |
---|---|
int |
getMaxParallelism() |
int |
getNumberOfSubpartitions() |
IntermediateResultPartitionID |
getPartitionId() |
ResultPartitionType |
getPartitionType() |
IntermediateDataSetID |
getResultId() |
ShuffleDescriptor |
getShuffleDescriptor() |
int |
getTotalNumberOfPartitions() |
boolean |
notifyPartitionDataAvailable() |
String |
toString() |
public ResultPartitionDeploymentDescriptor(PartitionDescriptor partitionDescriptor, ShuffleDescriptor shuffleDescriptor, int maxParallelism, boolean notifyPartitionDataAvailable)
public IntermediateDataSetID getResultId()
public IntermediateResultPartitionID getPartitionId()
public ResultPartitionType getPartitionType()
public int getTotalNumberOfPartitions()
public int getNumberOfSubpartitions()
public int getMaxParallelism()
public ShuffleDescriptor getShuffleDescriptor()
public boolean notifyPartitionDataAvailable()
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.