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