Skip to content

Commit a89741c

Browse files
committed
implement map_agg
1 parent 7bb6e15 commit a89741c

3 files changed

Lines changed: 829 additions & 0 deletions

File tree

datafusion/functions-aggregate/src/lib.rs

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -79,6 +79,7 @@ pub mod covariance;
7979
pub mod first_last;
8080
pub mod grouping;
8181
pub mod hyperloglog;
82+
pub mod map_agg;
8283
pub mod median;
8384
pub mod min_max;
8485
pub mod nth_value;
@@ -122,6 +123,7 @@ pub mod expr_fn {
122123
pub use super::first_last::first_value;
123124
pub use super::first_last::last_value;
124125
pub use super::grouping::grouping;
126+
pub use super::map_agg::map_agg;
125127
pub use super::median::median;
126128
pub use super::min_max::max;
127129
pub use super::min_max::min;
@@ -156,6 +158,7 @@ pub fn all_default_aggregate_functions() -> Vec<Arc<AggregateUDF>> {
156158
sum::sum_udaf(),
157159
min_max::max_udaf(),
158160
min_max::min_udaf(),
161+
map_agg::map_agg_udaf(),
159162
median::median_udaf(),
160163
count::count_udaf(),
161164
regr::regr_slope_udaf(),

0 commit comments

Comments
 (0)