Class StepFunctionValidator

  • All Implemented Interfaces:
    org.apache.flink.util.Visitor<org.apache.flink.api.common.operators.Operator<?>>

    public class StepFunctionValidator
    extends Object
    implements org.apache.flink.util.Visitor<org.apache.flink.api.common.operators.Operator<?>>
    A traversal that checks if the Workset of a delta iteration is used in the data flow of its step function.
    • Constructor Detail

      • StepFunctionValidator

        public StepFunctionValidator()
    • Method Detail

      • preVisit

        public boolean preVisit​(org.apache.flink.api.common.operators.Operator<?> visitable)
        Specified by:
        preVisit in interface org.apache.flink.util.Visitor<org.apache.flink.api.common.operators.Operator<?>>
      • postVisit

        public void postVisit​(org.apache.flink.api.common.operators.Operator<?> visitable)
        Specified by:
        postVisit in interface org.apache.flink.util.Visitor<org.apache.flink.api.common.operators.Operator<?>>
      • hasFoundWorkset

        public boolean hasFoundWorkset()