org.apache.flink.runtime.jobgraph.topology

Class DefaultLogicalPipelinedRegion

java.lang.Object

org.apache.flink.runtime.jobgraph.topology.DefaultLogicalPipelinedRegion

All Implemented Interfaces:

LogicalPipelinedRegion, PipelinedRegion<JobVertexID,IntermediateDataSetID,LogicalVertex,LogicalResult>

public class DefaultLogicalPipelinedRegion
extends Object
implements LogicalPipelinedRegion

Set of LogicalVertex that are connected through pipelined LogicalResult.

Constructor Summary

Constructors

Constructor and Description
DefaultLogicalPipelinedRegion(Set<? extends LogicalVertex> logicalVertices)

Method Summary

Modifier and Type	Method and Description
boolean	contains(JobVertexID vertexId) Returns whether the vertex is in this pipelined region or not.
LogicalVertex	getVertex(JobVertexID vertexId) Returns the vertex with the specified vertex id.
Iterable<? extends LogicalVertex>	getVertices() Returns vertices that are in this pipelined region.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultLogicalPipelinedRegion

public DefaultLogicalPipelinedRegion(Set<? extends LogicalVertex> logicalVertices)

Method Detail

getVertices

public Iterable<? extends LogicalVertex> getVertices()

Description copied from interface: PipelinedRegion

Returns vertices that are in this pipelined region.

Specified by:

getVertices in interface PipelinedRegion<JobVertexID,IntermediateDataSetID,LogicalVertex,LogicalResult>

Returns:

Iterable over all vertices in this pipelined region

getVertex

public LogicalVertex getVertex(JobVertexID vertexId)

Description copied from interface: PipelinedRegion

Returns the vertex with the specified vertex id.

Specified by:

getVertex in interface PipelinedRegion<JobVertexID,IntermediateDataSetID,LogicalVertex,LogicalResult>

Parameters:

vertexId - the vertex id used to look up the vertex

Returns:

the vertex with the specified id

contains

public boolean contains(JobVertexID vertexId)

Description copied from interface: PipelinedRegion

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

Specified by:

contains in interface PipelinedRegion<JobVertexID,IntermediateDataSetID,LogicalVertex,LogicalResult>

Parameters:

vertexId - the vertex id used to look up

Returns:

the vertex is in this pipelined region or not

toString

public String toString()

Overrides:

toString in class Object