Struct deltalake::datafusion::physical_optimizer::combine_partial_final_agg::CombinePartialFinalAggregate
source · pub struct CombinePartialFinalAggregate {}
Expand description
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§
source§impl CombinePartialFinalAggregate
impl CombinePartialFinalAggregate
pub fn new() -> CombinePartialFinalAggregate
Trait Implementations§
source§impl Default for CombinePartialFinalAggregate
impl Default for CombinePartialFinalAggregate
source§fn default() -> CombinePartialFinalAggregate
fn default() -> CombinePartialFinalAggregate
Returns the “default value” for a type. Read more
source§impl PhysicalOptimizerRule for CombinePartialFinalAggregate
impl PhysicalOptimizerRule for CombinePartialFinalAggregate
source§fn optimize(
&self,
plan: Arc<dyn ExecutionPlan>,
_config: &ConfigOptions
) -> Result<Arc<dyn ExecutionPlan>, DataFusionError>
fn optimize( &self, plan: Arc<dyn ExecutionPlan>, _config: &ConfigOptions ) -> Result<Arc<dyn ExecutionPlan>, DataFusionError>
Rewrite
plan
to an optimized formsource§fn schema_check(&self) -> bool
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.
Auto Trait Implementations§
impl RefUnwindSafe for CombinePartialFinalAggregate
impl Send for CombinePartialFinalAggregate
impl Sync for CombinePartialFinalAggregate
impl Unpin for CombinePartialFinalAggregate
impl UnwindSafe for CombinePartialFinalAggregate
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more