org.apache.flink.runtime.scheduler.strategy

Interface SchedulingResultPartition

All Superinterfaces:

Result<ExecutionVertexID,IntermediateResultPartitionID,SchedulingExecutionVertex,SchedulingResultPartition>

public interface SchedulingResultPartition
extends Result<ExecutionVertexID,IntermediateResultPartitionID,SchedulingExecutionVertex,SchedulingResultPartition>

Representation of IntermediateResultPartition.

Method Summary

Modifier and Type	Method and Description
List<ConsumedPartitionGroup>	getConsumedPartitionGroups() Gets the ConsumedPartitionGroups this partition belongs to.
List<ConsumerVertexGroup>	getConsumerVertexGroups() Gets the ConsumerVertexGroups.
IntermediateDataSetID	getResultId() Gets id of the intermediate result.
ResultPartitionState	getState() Gets the ResultPartitionState.

Methods inherited from interface org.apache.flink.runtime.topology.Result

getId, getProducer, getResultType

Method Detail

getResultId

IntermediateDataSetID getResultId()

Gets id of the intermediate result.

Returns:

id of the intermediate result

getState

ResultPartitionState getState()

Gets the ResultPartitionState.

Returns:

result partition state

getConsumerVertexGroups

List<ConsumerVertexGroup> getConsumerVertexGroups()

Gets the ConsumerVertexGroups.

Returns:

list of ConsumerVertexGroups

getConsumedPartitionGroups

List<ConsumedPartitionGroup> getConsumedPartitionGroups()

Gets the ConsumedPartitionGroups this partition belongs to.

Returns:

list of ConsumedPartitionGroups