public class IntermediateResultPartition extends Object
Constructor and Description |
---|
IntermediateResultPartition(IntermediateResult totalResult,
ExecutionVertex producer,
int partitionNumber,
EdgeManager edgeManager) |
Modifier and Type | Method and Description |
---|---|
void |
addConsumers(ConsumerVertexGroup consumers) |
boolean |
canBeReleased() |
List<ConsumedPartitionGroup> |
getConsumedPartitionGroups() |
List<ConsumerVertexGroup> |
getConsumerVertexGroups() |
IntermediateResult |
getIntermediateResult() |
int |
getNumberOfSubpartitions() |
IntermediateResultPartitionID |
getPartitionId() |
int |
getPartitionNumber() |
ExecutionVertex |
getProducer() |
ResultPartitionType |
getResultType() |
boolean |
hasDataAllProduced() |
boolean |
isNumberOfPartitionConsumersUndefined() |
void |
markPartitionGroupReleasable(ConsumedPartitionGroup partitionGroup) |
public IntermediateResultPartition(IntermediateResult totalResult, ExecutionVertex producer, int partitionNumber, EdgeManager edgeManager)
public void markPartitionGroupReleasable(ConsumedPartitionGroup partitionGroup)
public boolean canBeReleased()
public ExecutionVertex getProducer()
public int getPartitionNumber()
public IntermediateResult getIntermediateResult()
public IntermediateResultPartitionID getPartitionId()
public ResultPartitionType getResultType()
public List<ConsumerVertexGroup> getConsumerVertexGroups()
public List<ConsumedPartitionGroup> getConsumedPartitionGroups()
public boolean isNumberOfPartitionConsumersUndefined()
public int getNumberOfSubpartitions()
public boolean hasDataAllProduced()
public void addConsumers(ConsumerVertexGroup consumers)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.