You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@arrow.apache.org by al...@apache.org on 2022/12/22 20:55:29 UTC
[arrow-datafusion] branch master updated (77991a3d4 -> afb1ae230)
This is an automated email from the ASF dual-hosted git repository.
alamb pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/arrow-datafusion.git
from 77991a3d4 FOLLOWUP: remove more recursion in optimizer rules. (#4687)
add afb1ae230 Support min max aggregates in window functions with sliding windows (#4675)
No new revisions were added by this update.
Summary of changes:
datafusion/core/src/physical_plan/windows/mod.rs | 29 +-
datafusion/core/tests/sql/aggregates.rs | 54 ++++
datafusion/expr/src/window_frame.rs | 10 +
datafusion/physical-expr/src/aggregate/average.rs | 18 +-
datafusion/physical-expr/src/aggregate/count.rs | 4 +
datafusion/physical-expr/src/aggregate/min_max.rs | 159 ++++++++--
datafusion/physical-expr/src/aggregate/mod.rs | 9 +
.../physical-expr/src/aggregate/moving_min_max.rs | 335 +++++++++++++++++++++
.../physical-expr/src/aggregate/row_accumulator.rs | 18 ++
datafusion/physical-expr/src/aggregate/sum.rs | 22 +-
datafusion/physical-expr/src/window/aggregate.rs | 9 -
datafusion/physical-expr/src/window/mod.rs | 2 +
.../window/{aggregate.rs => sliding_aggregate.rs} | 8 +-
13 files changed, 602 insertions(+), 75 deletions(-)
create mode 100644 datafusion/physical-expr/src/aggregate/moving_min_max.rs
copy datafusion/physical-expr/src/window/{aggregate.rs => sliding_aggregate.rs} (96%)