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