org.apache.flink.runtime.executiongraph

Interface IntermediateResultInfo

All Known Subinterfaces:

BlockingResultInfo

All Known Implementing Classes:

AllToAllBlockingResultInfo, PointwiseBlockingResultInfo

public interface IntermediateResultInfo

Method Summary

Modifier and Type	Method and Description
int	getNumPartitions() Get number of partitions for this result.
int	getNumSubpartitions(int partitionIndex) Get number of subpartitions for the given partition.
IntermediateDataSetID	getResultId() Get the intermediate result id.
boolean	isBroadcast() Whether it is a broadcast result.
boolean	isPointwise() Whether it is a pointwise result.

Method Detail

getResultId

IntermediateDataSetID getResultId()

Get the intermediate result id.

Returns:

the intermediate result id

isBroadcast

boolean isBroadcast()

Whether it is a broadcast result.

Returns:

whether it is a broadcast result

isPointwise

boolean isPointwise()

Whether it is a pointwise result.

Returns:

whether it is a pointwise result

getNumPartitions

int getNumPartitions()

Get number of partitions for this result.

Returns:

the number of partitions in this result

getNumSubpartitions

int getNumSubpartitions(int partitionIndex)

Get number of subpartitions for the given partition.

Parameters:

partitionIndex - the partition index

Returns:

the number of subpartitions of the partition