Interface SchedulingResultPartition
-
- All Superinterfaces:
Result<ExecutionVertexID,IntermediateResultPartitionID,SchedulingExecutionVertex,SchedulingResultPartition>
public interface SchedulingResultPartition extends Result<ExecutionVertexID,IntermediateResultPartitionID,SchedulingExecutionVertex,SchedulingResultPartition>
Representation ofIntermediateResultPartition
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description List<ConsumedPartitionGroup>
getConsumedPartitionGroups()
Gets theConsumedPartitionGroup
s this partition belongs to.List<ConsumerVertexGroup>
getConsumerVertexGroups()
Gets theConsumerVertexGroup
s.IntermediateDataSetID
getResultId()
Gets id of the intermediate result.ResultPartitionState
getState()
Gets theResultPartitionState
.-
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 theResultPartitionState
.- Returns:
- result partition state
-
getConsumerVertexGroups
List<ConsumerVertexGroup> getConsumerVertexGroups()
Gets theConsumerVertexGroup
s.- Returns:
- list of
ConsumerVertexGroup
s
-
getConsumedPartitionGroups
List<ConsumedPartitionGroup> getConsumedPartitionGroups()
Gets theConsumedPartitionGroup
s this partition belongs to.- Returns:
- list of
ConsumedPartitionGroup
s
-
-