org.apache.flink.runtime.topology

Interface Topology<VID extends VertexID,RID extends ResultID,V extends Vertex<VID,RID,V,R>,R extends Result<VID,RID,V,R>,PR extends PipelinedRegion<VID,RID,V,R>>

All Superinterfaces:

BaseTopology<VID,RID,V,R>

All Known Subinterfaces:

LogicalTopology, SchedulingTopology

All Known Implementing Classes:

DefaultExecutionTopology, DefaultLogicalTopology

public interface Topology<VID extends VertexID,RID extends ResultID,V extends Vertex<VID,RID,V,R>,R extends Result<VID,RID,V,R>,PR extends PipelinedRegion<VID,RID,V,R>>
extends BaseTopology<VID,RID,V,R>

Extends the BaseTopology by pipelined regions.

Method Summary

Modifier and Type	Method and Description
Iterable<? extends PR>	getAllPipelinedRegions() Returns all pipelined regions in this topology.
default PR	getPipelinedRegionOfVertex(VID vertexId) The pipelined region for a specified vertex.

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

getVertices

Method Detail

getAllPipelinedRegions

Iterable<? extends PR> getAllPipelinedRegions()

Returns all pipelined regions in this topology.

Returns:

Iterable over pipelined regions in this topology

getPipelinedRegionOfVertex

default PR getPipelinedRegionOfVertex(VID vertexId)

The pipelined region for a specified vertex.

Parameters:

vertexId - the vertex id identifying the vertex for which the pipelined region should be returned

Returns:

the pipelined region of the vertex

Throws:

IllegalArgumentException - if there is no vertex in this topology with the specified vertex id