public class IntermediateResultPartition extends Object
Constructor and Description |
---|
IntermediateResultPartition(IntermediateResult totalResult,
ExecutionVertex producer,
int partitionNumber) |
Modifier and Type | Method and Description |
---|---|
List<List<ExecutionEdge>> |
getConsumers() |
IntermediateResult |
getIntermediateResult() |
IntermediateResultPartitionID |
getPartitionId() |
int |
getPartitionNumber() |
ExecutionVertex |
getProducer() |
ResultPartitionType |
getResultType() |
boolean |
isConsumable() |
void |
markDataProduced() |
public IntermediateResultPartition(IntermediateResult totalResult, ExecutionVertex producer, int partitionNumber)
public ExecutionVertex getProducer()
public int getPartitionNumber()
public IntermediateResult getIntermediateResult()
public IntermediateResultPartitionID getPartitionId()
public ResultPartitionType getResultType()
public List<List<ExecutionEdge>> getConsumers()
public void markDataProduced()
public boolean isConsumable()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.