GraphCreatingVisitor (Flink : Optimizer 1.18.1-cp2 API)

java.lang.Object
- org.apache.flink.optimizer.traversals.GraphCreatingVisitor

All Implemented Interfaces:

org.apache.flink.util.Visitor<org.apache.flink.api.common.operators.Operator<?>>
```
public class GraphCreatingVisitor
extends Object
implements org.apache.flink.util.Visitor<org.apache.flink.api.common.operators.Operator<?>>
```
This traversal creates the optimizer DAG from a program. It works as a visitor that walks the program's flow in a depth-first fashion, starting from the data sinks. During the descent it creates an optimizer node for each operator, respectively data source or sink. During the ascent it connects the nodes to the full graph.

Constructor Summary

Constructors
Constructor Description

GraphCreatingVisitor(int defaultParallelism, org.apache.flink.api.common.ExecutionMode defaultDataExchangeMode)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`List<DataSinkNode>`	`getSinks()`
`void`	`postVisit(org.apache.flink.api.common.operators.Operator<?> c)`
`boolean`	`preVisit(org.apache.flink.api.common.operators.Operator<?> c)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GraphCreatingVisitor

public GraphCreatingVisitor(int defaultParallelism,
                            org.apache.flink.api.common.ExecutionMode defaultDataExchangeMode)

Method Detail
- getSinks
```
public List<DataSinkNode> getSinks()
```
- preVisit
```
public boolean preVisit(org.apache.flink.api.common.operators.Operator<?> c)
```
  Specified by:
  
  preVisit in interface org.apache.flink.util.Visitor<org.apache.flink.api.common.operators.Operator<?>>
- postVisit
```
public void postVisit(org.apache.flink.api.common.operators.Operator<?> c)
```
  Specified by:
  
  postVisit in interface org.apache.flink.util.Visitor<org.apache.flink.api.common.operators.Operator<?>>