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

All Methods Instance Methods Abstract Methods Default Methods
Modifier and Type	Method	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

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>>

Method Summary

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

Method Detail

getAllPipelinedRegions

getPipelinedRegionOfVertex

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>>