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 descend, it creates an optimizer node for each operator, respectively data source or -sink. During the ascend, 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)
boolean	preVisit(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,
                            ExecutionMode defaultDataExchangeMode)

Method Detail

getSinks

public List<DataSinkNode> getSinks()

preVisit

public boolean preVisit(Operator<?> c)

Specified by:

preVisit in interface Visitor<Operator<?>>

Returns:

True, if the traversal should continue, false otherwise.

postVisit

public void postVisit(Operator<?> c)

Specified by:

postVisit in interface Visitor<Operator<?>>