Class GroupAggregationAnalyzer
- java.lang.Object
-
- org.apache.flink.table.planner.analyze.GroupAggregationAnalyzer
-
- All Implemented Interfaces:
PlanAnalyzer
@Internal public class GroupAggregationAnalyzer extends Object implements PlanAnalyzer
An implementation ofPlanAnalyzer
to analyze whether group aggregation can be optimized to local-global two_phase aggregation by tuning table configurations.
-
-
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 GroupAggregationAnalyzer
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 GroupAggregationAnalyzer 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
-
-