Package org.apache.flink.runtime.executiongraph

Class IntermediateResultPartition

java.lang.Object

org.apache.flink.runtime.executiongraph.IntermediateResultPartition

public class IntermediateResultPartition
extends Object

Constructor Summary

Constructors

Constructor	Description
IntermediateResultPartition(IntermediateResult totalResult, ExecutionVertex producer, int partitionNumber, EdgeManager edgeManager)

Method Summary

Modifier and Type	Method	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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

IntermediateResultPartition

public IntermediateResultPartition(IntermediateResult totalResult,
                                   ExecutionVertex producer,
                                   int partitionNumber,
                                   EdgeManager edgeManager)

Method Detail

markPartitionGroupReleasable

public void markPartitionGroupReleasable(ConsumedPartitionGroup partitionGroup)

canBeReleased

public boolean canBeReleased()

getProducer

public ExecutionVertex getProducer()

getPartitionNumber

public int getPartitionNumber()

getIntermediateResult

public IntermediateResult getIntermediateResult()

getPartitionId

public IntermediateResultPartitionID getPartitionId()

getResultType

public ResultPartitionType getResultType()

getConsumerVertexGroups

public List<ConsumerVertexGroup> getConsumerVertexGroups()

getConsumedPartitionGroups

public List<ConsumedPartitionGroup> getConsumedPartitionGroups()

isNumberOfPartitionConsumersUndefined

public boolean isNumberOfPartitionConsumersUndefined()

getNumberOfSubpartitions

public int getNumberOfSubpartitions()

hasDataAllProduced

public boolean hasDataAllProduced()

addConsumers

public void addConsumers(ConsumerVertexGroup consumers)