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