This is an automated email from the ASF dual-hosted git repository.
alamb pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/arrow-datafusion.git
from c9935ae52e fix: common_subexpr_eliminate rule should not apply to
short-circuit expression (#8928)
add edec418924 Support GroupsAccumulator accumulator for udaf (#8892)
No new revisions were added by this update.
Summary of changes:
datafusion-examples/Cargo.toml | 1 +
datafusion-examples/examples/advanced_udaf.rs | 220 +++++++++++++++++++--
.../tests/user_defined/user_defined_aggregates.rs | 128 +++++++++++-
.../mod.rs => expr/src/groups_accumulator.rs} | 7 -
datafusion/expr/src/lib.rs | 2 +
datafusion/expr/src/udaf.rs | 29 ++-
datafusion/physical-expr/src/aggregate/average.rs | 5 +-
.../physical-expr/src/aggregate/bit_and_or_xor.rs | 4 +-
.../physical-expr/src/aggregate/bool_and_or.rs | 4 +-
datafusion/physical-expr/src/aggregate/count.rs | 5 +-
.../src/aggregate/groups_accumulator/accumulate.rs | 13 +-
.../src/aggregate/groups_accumulator/adapter.rs | 3 +-
.../src/aggregate/groups_accumulator/bool_op.rs | 5 +-
.../src/aggregate/groups_accumulator/mod.rs | 138 +------------
.../src/aggregate/groups_accumulator/prim_op.rs | 5 +-
datafusion/physical-expr/src/aggregate/min_max.rs | 4 +-
datafusion/physical-expr/src/aggregate/mod.rs | 3 +-
datafusion/physical-expr/src/aggregate/sum.rs | 4 +-
datafusion/physical-expr/src/expressions/mod.rs | 5 +-
datafusion/physical-expr/src/lib.rs | 4 +-
.../src/aggregates/group_values/mod.rs | 2 +-
.../src/aggregates/group_values/primitive.rs | 2 +-
.../src/aggregates/group_values/row.rs | 2 +-
.../physical-plan/src/aggregates/order/full.rs | 2 +-
.../physical-plan/src/aggregates/order/mod.rs | 3 +-
.../physical-plan/src/aggregates/order/partial.rs | 2 +-
.../physical-plan/src/aggregates/row_hash.rs | 3 +-
datafusion/physical-plan/src/udaf.rs | 9 +
28 files changed, 415 insertions(+), 199 deletions(-)
copy datafusion/{physical-expr/src/aggregate/groups_accumulator/mod.rs =>
expr/src/groups_accumulator.rs} (97%)
