Struct CombinePartialFinalAggregate

pub struct CombinePartialFinalAggregate {}

CombinePartialFinalAggregate optimizer rule combines the adjacent Partial and Final AggregateExecs into a Single AggregateExec if their grouping exprs and aggregate exprs equal.

This rule should be applied after the EnforceDistribution and EnforceSorting rules

Implementations

impl CombinePartialFinalAggregate

pub fn new() -> Self

Trait Implementations

impl Debug for CombinePartialFinalAggregate

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for CombinePartialFinalAggregate

fn default() -> CombinePartialFinalAggregate

Returns the “default value” for a type.

impl PhysicalOptimizerRule for CombinePartialFinalAggregate

fn optimize( &self, plan: Arc<dyn ExecutionPlan>, _config: &ConfigOptions, ) -> Result<Arc<dyn ExecutionPlan>>

Rewrite plan to an optimized form

fn name(&self) -> &str

A human readable name for this optimizer rule

fn schema_check(&self) -> bool

A flag to indicate whether the physical planner should valid the rule will not change the schema of the plan after the rewriting. Some of the optimization rules might change the nullable properties of the schema and should disable the schema check.