Class UnionParallelismAndForwardEnforcer

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

    public class UnionParallelismAndForwardEnforcer
    extends Object
    implements org.apache.flink.util.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 Detail

      • UnionParallelismAndForwardEnforcer

        public UnionParallelismAndForwardEnforcer()
    • 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>