public class DefaultSchedulingPipelinedRegion extends Object implements SchedulingPipelinedRegion
SchedulingPipelinedRegion
.Constructor and Description |
---|
DefaultSchedulingPipelinedRegion(Set<org.apache.flink.runtime.scheduler.adapter.DefaultExecutionVertex> defaultExecutionVertices,
Function<IntermediateResultPartitionID,org.apache.flink.runtime.scheduler.adapter.DefaultResultPartition> resultPartitionRetriever) |
Modifier and Type | Method and Description |
---|---|
boolean |
contains(ExecutionVertexID vertexId)
Returns whether the vertex is in this pipelined region or not.
|
Iterable<ConsumedPartitionGroup> |
getAllNonPipelinedConsumedPartitionGroups()
Get all distinct blocking
ConsumedPartitionGroup s. |
Iterable<ConsumedPartitionGroup> |
getAllReleaseBySchedulerConsumedPartitionGroups()
Get all distinct releaseByScheduler
ConsumedPartitionGroup s. |
org.apache.flink.runtime.scheduler.adapter.DefaultExecutionVertex |
getVertex(ExecutionVertexID vertexId)
Returns the vertex with the specified vertex id.
|
Iterable<org.apache.flink.runtime.scheduler.adapter.DefaultExecutionVertex> |
getVertices()
Returns vertices that are in this pipelined region.
|
public DefaultSchedulingPipelinedRegion(Set<org.apache.flink.runtime.scheduler.adapter.DefaultExecutionVertex> defaultExecutionVertices, Function<IntermediateResultPartitionID,org.apache.flink.runtime.scheduler.adapter.DefaultResultPartition> resultPartitionRetriever)
public Iterable<org.apache.flink.runtime.scheduler.adapter.DefaultExecutionVertex> getVertices()
PipelinedRegion
getVertices
in interface PipelinedRegion<ExecutionVertexID,IntermediateResultPartitionID,SchedulingExecutionVertex,SchedulingResultPartition>
public org.apache.flink.runtime.scheduler.adapter.DefaultExecutionVertex getVertex(ExecutionVertexID vertexId)
PipelinedRegion
getVertex
in interface PipelinedRegion<ExecutionVertexID,IntermediateResultPartitionID,SchedulingExecutionVertex,SchedulingResultPartition>
vertexId
- the vertex id used to look up the vertexpublic Iterable<ConsumedPartitionGroup> getAllNonPipelinedConsumedPartitionGroups()
SchedulingPipelinedRegion
ConsumedPartitionGroup
s.getAllNonPipelinedConsumedPartitionGroups
in interface SchedulingPipelinedRegion
ConsumedPartitionGroup
spublic Iterable<ConsumedPartitionGroup> getAllReleaseBySchedulerConsumedPartitionGroups()
SchedulingPipelinedRegion
ConsumedPartitionGroup
s.getAllReleaseBySchedulerConsumedPartitionGroups
in interface SchedulingPipelinedRegion
ConsumedPartitionGroup
spublic boolean contains(ExecutionVertexID vertexId)
PipelinedRegion
contains
in interface PipelinedRegion<ExecutionVertexID,IntermediateResultPartitionID,SchedulingExecutionVertex,SchedulingResultPartition>
vertexId
- the vertex id used to look upCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.