org.apache.flink.optimizer.traversals

Class UnionParallelismAndForwardEnforcer

java.lang.Object

org.apache.flink.optimizer.traversals.UnionParallelismAndForwardEnforcer

All Implemented Interfaces:

Visitor<OptimizerNode>

public class UnionParallelismAndForwardEnforcer
extends Object
implements Visitor<OptimizerNode>

Enforces that all union nodes have the same parallelism as their successor (there must be only one!) and that the union node and its successor are connected by a forward ship strategy.

Constructor Summary

Constructors

Constructor and Description
UnionParallelismAndForwardEnforcer()

Method Summary

Modifier and Type	Method and Description
void	postVisit(OptimizerNode node) Method that is invoked after all child nodes or descendant nodes were visited.
boolean	preVisit(OptimizerNode node) 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

UnionParallelismAndForwardEnforcer

public UnionParallelismAndForwardEnforcer()

Method Detail

preVisit

public boolean preVisit(OptimizerNode node)

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

Returns:

True, if the traversal should continue, false otherwise.

postVisit

public void postVisit(OptimizerNode node)

Description copied from interface: Visitor

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

Specified by:

postVisit in interface Visitor<OptimizerNode>