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,
boolean isBroadcast,
boolean isAllToAllDistribution) |
Modifier and Type | Method and Description |
---|---|
static PartitionDescriptor |
from(IntermediateResultPartition partition) |
int |
getNumberOfSubpartitions() |
IntermediateResultPartitionID |
getPartitionId() |
ResultPartitionType |
getPartitionType() |
IntermediateDataSetID |
getResultId() |
int |
getTotalNumberOfPartitions() |
boolean |
isAllToAllDistribution() |
boolean |
isBroadcast() |
String |
toString() |
@VisibleForTesting public PartitionDescriptor(IntermediateDataSetID resultId, int totalNumberOfPartitions, IntermediateResultPartitionID partitionId, ResultPartitionType partitionType, int numberOfSubpartitions, int connectionIndex, boolean isBroadcast, boolean isAllToAllDistribution)
public IntermediateDataSetID getResultId()
public int getTotalNumberOfPartitions()
public IntermediateResultPartitionID getPartitionId()
public ResultPartitionType getPartitionType()
public int getNumberOfSubpartitions()
public boolean isBroadcast()
public boolean isAllToAllDistribution()
public static PartitionDescriptor from(IntermediateResultPartition partition)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.