public interface SchedulingResultPartition extends Result<ExecutionVertexID,IntermediateResultPartitionID,SchedulingExecutionVertex,SchedulingResultPartition>
IntermediateResultPartition
.Modifier and Type | Method and Description |
---|---|
List<ConsumedPartitionGroup> |
getConsumedPartitionGroups()
Gets the
ConsumedPartitionGroup s this partition belongs to. |
Optional<ConsumerVertexGroup> |
getConsumerVertexGroup()
Gets the
ConsumerVertexGroup . |
IntermediateDataSetID |
getResultId()
Gets id of the intermediate result.
|
ResultPartitionState |
getState()
Gets the
ResultPartitionState . |
getId, getProducer, getResultType
IntermediateDataSetID getResultId()
ResultPartitionState getState()
ResultPartitionState
.Optional<ConsumerVertexGroup> getConsumerVertexGroup()
ConsumerVertexGroup
.ConsumerVertexGroup
if consumers exists, otherwise Optional.empty()
.List<ConsumedPartitionGroup> getConsumedPartitionGroups()
ConsumedPartitionGroup
s this partition belongs to.ConsumedPartitionGroup
sCopyright © 2014–2023 The Apache Software Foundation. All rights reserved.