public class DefaultSchedulingPipelinedRegion extends Object implements SchedulingPipelinedRegion
SchedulingPipelinedRegion
.Constructor and Description |
---|
DefaultSchedulingPipelinedRegion(Set<org.apache.flink.runtime.scheduler.adapter.DefaultExecutionVertex> defaultExecutionVertices) |
Modifier and Type | Method and Description |
---|---|
Iterable<org.apache.flink.runtime.scheduler.adapter.DefaultResultPartition> |
getConsumedResults()
Returns the results that this pipelined region consumes.
|
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)
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<org.apache.flink.runtime.scheduler.adapter.DefaultResultPartition> getConsumedResults()
PipelinedRegion
getConsumedResults
in interface PipelinedRegion<ExecutionVertexID,IntermediateResultPartitionID,SchedulingExecutionVertex,SchedulingResultPartition>
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.