org.apache.flink.table.planner.analyze

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 of PlanAnalyzer 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 and Description
static GroupAggregationAnalyzer	INSTANCE

Method Summary

Modifier and Type	Method and Description
Optional<PlanAnalyzer.AnalyzedResult>	analyze(org.apache.flink.table.planner.plan.nodes.FlinkRelNode rel) Analyze the optimized RelNode and return PlanAnalyzer.AnalyzedResult.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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 optimized RelNode and return PlanAnalyzer.AnalyzedResult.

Specified by:

analyze in interface PlanAnalyzer