org.apache.flink.runtime.jobgraph.topology

Class DefaultLogicalTopology

java.lang.Object

org.apache.flink.runtime.jobgraph.topology.DefaultLogicalTopology

All Implemented Interfaces:

LogicalTopology, BaseTopology<JobVertexID,IntermediateDataSetID,LogicalVertex,LogicalResult>, Topology<JobVertexID,IntermediateDataSetID,LogicalVertex,LogicalResult,LogicalPipelinedRegion>

public class DefaultLogicalTopology
extends Object
implements LogicalTopology

Default implementation of LogicalTopology. It is an adapter of JobGraph.

Method Summary

Modifier and Type	Method and Description
static DefaultLogicalTopology	fromJobGraph(JobGraph jobGraph)
static DefaultLogicalTopology	fromTopologicallySortedJobVertices(List<JobVertex> jobVertices)
Iterable<DefaultLogicalPipelinedRegion>	getAllPipelinedRegions() Returns all pipelined regions in this topology.
DefaultLogicalVertex	getVertex(JobVertexID vertexId)
Iterable<DefaultLogicalVertex>	getVertices() Returns an iterable over all vertices, topologically sorted.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.runtime.topology.Topology

getPipelinedRegionOfVertex

Method Detail

fromJobGraph

public static DefaultLogicalTopology fromJobGraph(JobGraph jobGraph)

fromTopologicallySortedJobVertices

public static DefaultLogicalTopology fromTopologicallySortedJobVertices(List<JobVertex> jobVertices)

getVertices

public Iterable<DefaultLogicalVertex> getVertices()

Description copied from interface: BaseTopology

Returns an iterable over all vertices, topologically sorted.

Specified by:

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

Returns:

topologically sorted iterable over all vertices

getVertex

public DefaultLogicalVertex getVertex(JobVertexID vertexId)

getAllPipelinedRegions

public Iterable<DefaultLogicalPipelinedRegion> getAllPipelinedRegions()

Description copied from interface: Topology

Returns all pipelined regions in this topology.

Specified by:

getAllPipelinedRegions in interface Topology<JobVertexID,IntermediateDataSetID,LogicalVertex,LogicalResult,LogicalPipelinedRegion>

Returns:

Iterable over pipelined regions in this topology