Class NonDeterministicUpdateAnalyzer
- java.lang.Object
-
- org.apache.flink.table.planner.analyze.NonDeterministicUpdateAnalyzer
-
- All Implemented Interfaces:
PlanAnalyzer
@Internal public class NonDeterministicUpdateAnalyzer extends Object implements PlanAnalyzer
An implementation ofPlanAnalyzer
to analyze the potential risk of non-deterministic update whenOptimizerConfigOptions.TABLE_OPTIMIZER_NONDETERMINISTIC_UPDATE_STRATEGY
is ignored.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.flink.table.planner.analyze.PlanAnalyzer
PlanAnalyzer.AnalyzedResult
-
-
Field Summary
Fields Modifier and Type Field Description static NonDeterministicUpdateAnalyzer
INSTANCE
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Optional<PlanAnalyzer.AnalyzedResult>
analyze(org.apache.flink.table.planner.plan.nodes.FlinkRelNode rel)
Analyze the optimizedRelNode
and returnPlanAnalyzer.AnalyzedResult
.
-
-
-
Field Detail
-
INSTANCE
public static final NonDeterministicUpdateAnalyzer INSTANCE
-
-
Method Detail
-
analyze
public Optional<PlanAnalyzer.AnalyzedResult> analyze(org.apache.flink.table.planner.plan.nodes.FlinkRelNode rel)
Description copied from interface:PlanAnalyzer
Analyze the optimizedRelNode
and returnPlanAnalyzer.AnalyzedResult
.- Specified by:
analyze
in interfacePlanAnalyzer
-
-