org.apache.flink.optimizer.traversals

Class GraphCreatingVisitor

java.lang.Object

org.apache.flink.optimizer.traversals.GraphCreatingVisitor

All Implemented Interfaces:

Visitor<Operator<?>>

public class GraphCreatingVisitor
extends Object
implements Visitor<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 and Description
GraphCreatingVisitor(int defaultParallelism, ExecutionMode defaultDataExchangeMode)

Method Summary

Modifier and Type	Method and Description
List<DataSinkNode>	getSinks()
void	postVisit(Operator<?> c) Method that is invoked after all child nodes or descendant nodes were visited.
boolean	preVisit(Operator<?> c) Method that is invoked on the visit before visiting and child nodes or descendant nodes.

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,
                            ExecutionMode defaultDataExchangeMode)

Method Detail

getSinks

public List<DataSinkNode> getSinks()

preVisit

public boolean preVisit(Operator<?> c)

Description copied from interface: Visitor

Method that is invoked on the visit before visiting and child nodes or descendant nodes.

Specified by:

preVisit in interface Visitor<Operator<?>>

Returns:

True, if the traversal should continue, false otherwise.

postVisit

public void postVisit(Operator<?> c)

Description copied from interface: Visitor

Method that is invoked after all child nodes or descendant nodes were visited.

Specified by:

postVisit in interface Visitor<Operator<?>>