Class BranchesVisitor

  • All Implemented Interfaces:
    org.apache.flink.util.Visitor<OptimizerNode>

    public final class BranchesVisitor
    extends Object
    implements org.apache.flink.util.Visitor<OptimizerNode>
    This traversal of the optimizer DAG computes the information needed to track branches and joins in the data flow. This is important to support plans that are not a minimally connected DAG (Such plans are not trees, but at least one node feeds its output into more than one other node).
    • Constructor Detail

      • BranchesVisitor

        public BranchesVisitor()
    • Method Detail

      • preVisit

        public boolean preVisit​(OptimizerNode node)
        Specified by:
        preVisit in interface org.apache.flink.util.Visitor<OptimizerNode>
      • postVisit

        public void postVisit​(OptimizerNode node)
        Specified by:
        postVisit in interface org.apache.flink.util.Visitor<OptimizerNode>