org.apache.flink.runtime.scheduler.adapter

Class DefaultSchedulingPipelinedRegion

java.lang.Object

org.apache.flink.runtime.scheduler.adapter.DefaultSchedulingPipelinedRegion

All Implemented Interfaces:

SchedulingPipelinedRegion, PipelinedRegion<ExecutionVertexID,IntermediateResultPartitionID,SchedulingExecutionVertex,SchedulingResultPartition>

public class DefaultSchedulingPipelinedRegion
extends Object
implements SchedulingPipelinedRegion

Default implementation of SchedulingPipelinedRegion.

Constructor Summary

Constructors

Constructor and Description
DefaultSchedulingPipelinedRegion(Set<org.apache.flink.runtime.scheduler.adapter.DefaultExecutionVertex> defaultExecutionVertices, Function<IntermediateResultPartitionID,org.apache.flink.runtime.scheduler.adapter.DefaultResultPartition> resultPartitionRetriever)

Method Summary

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 ConsumedPartitionGroups.
Iterable<ConsumedPartitionGroup>	getAllReleaseBySchedulerConsumedPartitionGroups() Get all distinct releaseByScheduler ConsumedPartitionGroups.
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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultSchedulingPipelinedRegion

public DefaultSchedulingPipelinedRegion(Set<org.apache.flink.runtime.scheduler.adapter.DefaultExecutionVertex> defaultExecutionVertices,
                                        Function<IntermediateResultPartitionID,org.apache.flink.runtime.scheduler.adapter.DefaultResultPartition> resultPartitionRetriever)

Method Detail

getVertices

public Iterable<org.apache.flink.runtime.scheduler.adapter.DefaultExecutionVertex> getVertices()

Description copied from interface: PipelinedRegion

Returns vertices that are in this pipelined region.

Specified by:

getVertices in interface PipelinedRegion<ExecutionVertexID,IntermediateResultPartitionID,SchedulingExecutionVertex,SchedulingResultPartition>

Returns:

Iterable over all vertices in this pipelined region

getVertex

public org.apache.flink.runtime.scheduler.adapter.DefaultExecutionVertex getVertex(ExecutionVertexID vertexId)

Description copied from interface: PipelinedRegion

Returns the vertex with the specified vertex id.

Specified by:

getVertex in interface PipelinedRegion<ExecutionVertexID,IntermediateResultPartitionID,SchedulingExecutionVertex,SchedulingResultPartition>

Parameters:

vertexId - the vertex id used to look up the vertex

Returns:

the vertex with the specified id

getAllNonPipelinedConsumedPartitionGroups

public Iterable<ConsumedPartitionGroup> getAllNonPipelinedConsumedPartitionGroups()

Description copied from interface: SchedulingPipelinedRegion

Get all distinct blocking ConsumedPartitionGroups.

Specified by:

getAllNonPipelinedConsumedPartitionGroups in interface SchedulingPipelinedRegion

Returns:

set of ConsumedPartitionGroups

getAllReleaseBySchedulerConsumedPartitionGroups

public Iterable<ConsumedPartitionGroup> getAllReleaseBySchedulerConsumedPartitionGroups()

Description copied from interface: SchedulingPipelinedRegion

Get all distinct releaseByScheduler ConsumedPartitionGroups.

Specified by:

getAllReleaseBySchedulerConsumedPartitionGroups in interface SchedulingPipelinedRegion

Returns:

set of ConsumedPartitionGroups

contains

public boolean contains(ExecutionVertexID vertexId)

Description copied from interface: PipelinedRegion

Returns whether the vertex is in this pipelined region or not.

Specified by:

contains in interface PipelinedRegion<ExecutionVertexID,IntermediateResultPartitionID,SchedulingExecutionVertex,SchedulingResultPartition>

Parameters:

vertexId - the vertex id used to look up

Returns:

the vertex is in this pipelined region or not