| Interface | Description |
|---|---|
| PlanAnalyzer |
Plan analyzer analyzes the optimized physical plan and provide potential risk warnings and
optimization advice.
|
| PlanAnalyzer.AnalyzedResult |
The analyzed
PlanAdvice with a list of applicable RelNode ids. |
| Class | Description |
|---|---|
| FlinkStreamPlanAnalyzers |
A collection of
PlanAnalyzers for org.apache.flink.table.planner.delegation.StreamPlanner. |
| GroupAggregationAnalyzer |
An implementation of
PlanAnalyzer to analyze whether group aggregation can be optimized
to local-global two_phase aggregation by tuning table configurations. |
| NonDeterministicUpdateAnalyzer |
An implementation of
PlanAnalyzer to analyze the potential risk of non-deterministic
update when OptimizerConfigOptions.TABLE_OPTIMIZER_NONDETERMINISTIC_UPDATE_STRATEGY is
ignored. |
| PlanAdvice |
Plain POJO for advice provided by
PlanAnalyzer. |
| Enum | Description |
|---|---|
| PlanAdvice.Kind |
Categorize the semantics of a
PlanAdvice. |
| PlanAdvice.Scope |
Categorize the scope of a
PlanAdvice. |
Copyright © 2014–2025 The Apache Software Foundation. All rights reserved.