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 and Description
IntermediateResultPartition(IntermediateResult totalResult, ExecutionVertex producer, int partitionNumber, EdgeManager edgeManager)

Method Summary

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	isConsumable()
void	markDataProduced()
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()

getNumberOfSubpartitions

public int getNumberOfSubpartitions()

markDataProduced

public void markDataProduced()

isConsumable

public boolean isConsumable()

addConsumers

public void addConsumers(ConsumerVertexGroup consumers)