Skip to content

Commit 0840207

Browse files
committed
feat: implement GroupsAccumulator for count(DISTINCT) aggr
Signed-off-by: Ruihang Xia <waynestxia@gmail.com>
1 parent 87eec43 commit 0840207

File tree

2 files changed

+383
-9
lines changed
  • datafusion

2 files changed

+383
-9
lines changed

datafusion/functions-aggregate-common/src/aggregate/groups_accumulator/accumulate.rs

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,13 @@
1515
// specific language governing permissions and limitations
1616
// under the License.
1717

18-
//! [`GroupsAccumulator`] helpers: [`NullState`] and [`accumulate_indices`]
18+
//! [`GroupsAccumulator`] helpers: [`NullState`] and [`accumulate_indices`]-like functions.
19+
//!
20+
//! This mod provides various kinds of helper functions to work with [`GroupsAccumulator`],
21+
//! here is a quick summary of the functions provided and their purpose/differences:
22+
//! - [`accumulate`]: Accumulate a single, primitive value per group.
23+
//! - [`accumulate_multiple`]: Accumulate multiple, primitive values per group.
24+
//! - [`accumulate_indices`]: Accumulate indices only (without actual value) per group.
1925
//!
2026
//! [`GroupsAccumulator`]: datafusion_expr_common::groups_accumulator::GroupsAccumulator
2127

0 commit comments

Comments
 (0)