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) |
List<ConsumedPartitionGroup> |
getConsumedPartitionGroups() |
ConsumerVertexGroup |
getConsumerVertexGroup() |
Optional<ConsumerVertexGroup> |
getConsumerVertexGroupOptional() |
IntermediateResult |
getIntermediateResult() |
int |
getNumberOfSubpartitions() |
IntermediateResultPartitionID |
getPartitionId() |
int |
getPartitionNumber() |
ExecutionVertex |
getProducer() |
ResultPartitionType |
getResultType() |
boolean |
isConsumable() |
void |
markDataProduced() |
public IntermediateResultPartition(IntermediateResult totalResult, ExecutionVertex producer, int partitionNumber, EdgeManager edgeManager)
public ExecutionVertex getProducer()
public int getPartitionNumber()
public IntermediateResult getIntermediateResult()
public IntermediateResultPartitionID getPartitionId()
public ResultPartitionType getResultType()
public ConsumerVertexGroup getConsumerVertexGroup()
public Optional<ConsumerVertexGroup> getConsumerVertexGroupOptional()
public List<ConsumedPartitionGroup> getConsumedPartitionGroups()
public int getNumberOfSubpartitions()
public void markDataProduced()
public boolean isConsumable()
public void addConsumers(ConsumerVertexGroup consumers)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.