Class StepFunctionValidator
- java.lang.Object
-
- org.apache.flink.optimizer.traversals.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 Summary
Constructors Constructor Description StepFunctionValidator()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanhasFoundWorkset()voidpostVisit(org.apache.flink.api.common.operators.Operator<?> visitable)booleanpreVisit(org.apache.flink.api.common.operators.Operator<?> visitable)
-
-
-
Method Detail
-
preVisit
public boolean preVisit(org.apache.flink.api.common.operators.Operator<?> visitable)
- Specified by:
preVisitin interfaceorg.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:
postVisitin interfaceorg.apache.flink.util.Visitor<org.apache.flink.api.common.operators.Operator<?>>
-
hasFoundWorkset
public boolean hasFoundWorkset()
-
-