Merge pull request #11 from lutengda/cnosdb_datafusion_27

move push_down_aggregation code to cnosdb
cnosdb · Sep 9, 2024 · cf5e7fe · cf5e7fe
2 parents 5367e31 + 940c59c
commit cf5e7fe
Show file tree

Hide file tree

Showing 3 changed files with 0 additions and 252 deletions.
diff --git a/datafusion/optimizer/src/lib.rs b/datafusion/optimizer/src/lib.rs
@@ -31,7 +31,6 @@ pub mod filter_null_join_keys;
 pub mod merge_projection;
 pub mod optimizer;
 pub mod propagate_empty_relation;
-pub mod push_down_aggregation;
 pub mod push_down_filter;
 pub mod push_down_limit;
 pub mod push_down_projection;

diff --git a/datafusion/optimizer/src/optimizer.rs b/datafusion/optimizer/src/optimizer.rs
@@ -31,7 +31,6 @@ use crate::filter_null_join_keys::FilterNullJoinKeys;
 use crate::merge_projection::MergeProjection;
 use crate::plan_signature::LogicalPlanSignature;
 use crate::propagate_empty_relation::PropagateEmptyRelation;
-use crate::push_down_aggregation::PushDownAggregation;
 use crate::push_down_filter::PushDownFilter;
 use crate::push_down_limit::PushDownLimit;
 use crate::push_down_projection::PushDownProjection;
@@ -253,7 +252,6 @@ impl Optimizer {
             Arc::new(CommonSubexprEliminate::new()),
             Arc::new(PushDownProjection::new()),
             Arc::new(EliminateProjection::new()),
-            Arc::new(PushDownAggregation::new()),
             // PushDownProjection can pushdown Projections through Limits, do PushDownLimit again.
             Arc::new(PushDownLimit::new()),
         ];

diff --git a/datafusion/optimizer/src/push_down_aggregation.rs b/datafusion/optimizer/src/push_down_aggregation.rs