org.apache.flink.optimizer.traversals

Class PlanFinalizer

java.lang.Object

org.apache.flink.optimizer.traversals.PlanFinalizer

All Implemented Interfaces:

Visitor<PlanNode>

public class PlanFinalizer
extends Object
implements Visitor<PlanNode>

This visitor traverses the selected execution plan and finalizes it:

• The graph of nodes is double-linked (links from child to parent are inserted).
• If unions join static and dynamic paths, the cache is marked as a memory consumer.
• Relative memory fractions are assigned to all nodes.
• All nodes are collected into a set.

Constructor Summary

Constructors

Constructor and Description
PlanFinalizer() Creates a new plan finalizer.

Method Summary

Modifier and Type	Method and Description
OptimizedPlan	createFinalPlan(List<SinkPlanNode> sinks, String jobName, Plan originalPlan)
void	postVisit(PlanNode visitable) Method that is invoked after all child nodes or descendant nodes were visited.
boolean	preVisit(PlanNode visitable) 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

PlanFinalizer

public PlanFinalizer()

Creates a new plan finalizer.

Method Detail

createFinalPlan

public OptimizedPlan createFinalPlan(List<SinkPlanNode> sinks,
                                     String jobName,
                                     Plan originalPlan)

preVisit

public boolean preVisit(PlanNode visitable)

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

Returns:

True, if the traversal should continue, false otherwise.

postVisit

public void postVisit(PlanNode visitable)

Description copied from interface: Visitor

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

Specified by:

postVisit in interface Visitor<PlanNode>