public class PartitionDescriptor extends Object implements Serializable
ShuffleMaster
to obtain ShuffleDescriptor
.Constructor and Description |
---|
PartitionDescriptor(IntermediateDataSetID resultId,
int totalNumberOfPartitions,
IntermediateResultPartitionID partitionId,
ResultPartitionType partitionType,
int numberOfSubpartitions,
int connectionIndex) |
Modifier and Type | Method and Description |
---|---|
static PartitionDescriptor |
from(IntermediateResultPartition partition) |
int |
getNumberOfSubpartitions() |
IntermediateResultPartitionID |
getPartitionId() |
ResultPartitionType |
getPartitionType() |
IntermediateDataSetID |
getResultId() |
int |
getTotalNumberOfPartitions() |
String |
toString() |
@VisibleForTesting public PartitionDescriptor(IntermediateDataSetID resultId, int totalNumberOfPartitions, IntermediateResultPartitionID partitionId, ResultPartitionType partitionType, int numberOfSubpartitions, int connectionIndex)
public IntermediateDataSetID getResultId()
public int getTotalNumberOfPartitions()
public IntermediateResultPartitionID getPartitionId()
public ResultPartitionType getPartitionType()
public int getNumberOfSubpartitions()
public static PartitionDescriptor from(IntermediateResultPartition partition)
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.