This is an automated email from the ASF dual-hosted git repository.
nju_yaho pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/arrow-datafusion.git
from f0d544f6e6 minor: Add `Expr::between` to clean up boilerplate (#5967)
add 1600a307f2 Add new physical rule CombinePartialFinalAggregate (#5837)
No new revisions were added by this update.
Summary of changes:
datafusion/core/src/execution/context.rs | 4 +
.../combine_partial_final_agg.rs | 434 +++++++++++++++++++++
datafusion/core/src/physical_optimizer/mod.rs | 1 +
.../core/src/physical_plan/aggregates/mod.rs | 42 +-
.../src/physical_plan/aggregates/no_grouping.rs | 6 +-
.../core/src/physical_plan/aggregates/row_hash.rs | 30 +-
datafusion/core/src/physical_plan/udaf.rs | 20 +
datafusion/core/tests/sql/joins.rs | 165 ++++++++
.../core/tests/sqllogictests/test_files/window.slt | 31 +-
.../physical-expr/src/aggregate/approx_distinct.rs | 14 +
.../physical-expr/src/aggregate/approx_median.rs | 15 +
.../src/aggregate/approx_percentile_cont.rs | 25 ++
.../approx_percentile_cont_with_weight.rs | 15 +
.../physical-expr/src/aggregate/array_agg.rs | 14 +
.../src/aggregate/array_agg_distinct.rs | 14 +
datafusion/physical-expr/src/aggregate/average.rs | 15 +
.../physical-expr/src/aggregate/correlation.rs | 12 +
datafusion/physical-expr/src/aggregate/count.rs | 48 ++-
.../physical-expr/src/aggregate/count_distinct.rs | 14 +
.../physical-expr/src/aggregate/covariance.rs | 23 ++
datafusion/physical-expr/src/aggregate/grouping.rs | 15 +
datafusion/physical-expr/src/aggregate/median.rs | 14 +
datafusion/physical-expr/src/aggregate/min_max.rs | 29 ++
datafusion/physical-expr/src/aggregate/mod.rs | 5 +-
datafusion/physical-expr/src/aggregate/stddev.rs | 20 +
datafusion/physical-expr/src/aggregate/sum.rs | 15 +
.../physical-expr/src/aggregate/sum_distinct.rs | 19 +
datafusion/physical-expr/src/aggregate/utils.rs | 21 +
datafusion/physical-expr/src/aggregate/variance.rs | 19 +
datafusion/proto/proto/datafusion.proto | 1 +
datafusion/proto/src/generated/pbjson.rs | 3 +
datafusion/proto/src/generated/prost.rs | 3 +
datafusion/proto/src/physical_plan/mod.rs | 2 +
33 files changed, 1068 insertions(+), 40 deletions(-)
create mode 100644
datafusion/core/src/physical_optimizer/combine_partial_final_agg.rs
