public interface SchedulingPipelinedRegion extends PipelinedRegion<ExecutionVertexID,IntermediateResultPartitionID,SchedulingExecutionVertex,SchedulingResultPartition>
ExecutionGraph
level.Modifier and Type | Method and Description |
---|---|
Iterable<ConsumedPartitionGroup> |
getAllBlockingConsumedPartitionGroups()
Get all distinct blocking
ConsumedPartitionGroup s. |
contains, getVertex, getVertices
Iterable<ConsumedPartitionGroup> getAllBlockingConsumedPartitionGroups()
ConsumedPartitionGroup
s.ConsumedPartitionGroup
sCopyright © 2014–2022 The Apache Software Foundation. All rights reserved.