org.apache.flink.runtime.executiongraph

Class IntermediateResult

java.lang.Object

org.apache.flink.runtime.executiongraph.IntermediateResult

public class IntermediateResult
extends Object

Constructor Summary

Constructors

Constructor and Description
IntermediateResult(IntermediateDataSetID id, ExecutionJobVertex producer, int numParallelProducers, ResultPartitionType resultType)

Method Summary

Modifier and Type	Method and Description
int	getConnectionIndex()
IntermediateDataSetID	getId()
int	getNumberOfAssignedPartitions()
IntermediateResultPartition	getPartitionById(IntermediateResultPartitionID resultPartitionId) Returns the partition with the given ID.
IntermediateResultPartition[]	getPartitions()
ExecutionJobVertex	getProducer()
ResultPartitionType	getResultType()
int	registerConsumer()
void	setPartition(int partitionNumber, IntermediateResultPartition partition)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

IntermediateResult

public IntermediateResult(IntermediateDataSetID id,
                          ExecutionJobVertex producer,
                          int numParallelProducers,
                          ResultPartitionType resultType)

Method Detail

setPartition

public void setPartition(int partitionNumber,
                         IntermediateResultPartition partition)

getId

public IntermediateDataSetID getId()

getProducer

public ExecutionJobVertex getProducer()

getPartitions

public IntermediateResultPartition[] getPartitions()

getPartitionById

public IntermediateResultPartition getPartitionById(IntermediateResultPartitionID resultPartitionId)

Returns the partition with the given ID.

Parameters:

resultPartitionId - ID of the partition to look up

Returns:

Intermediate result partition with the given ID

Throws:

NullPointerException - If partition ID null

IllegalArgumentException - Thrown if unknown partition ID

getNumberOfAssignedPartitions

public int getNumberOfAssignedPartitions()

getResultType

public ResultPartitionType getResultType()

registerConsumer

public int registerConsumer()

getConnectionIndex

public int getConnectionIndex()

toString

public String toString()

Overrides:

toString in class Object