nodedb 0.2.0

Local-first, real-time, edge-to-cloud hybrid database for multi-modal workloads
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

// SPDX-License-Identifier: BUSL-1.1

//! Streaming aggregate accumulators for the generic GROUP BY path.
//!
//! Each `AggAccum` variant holds only the derived state needed to compute the
//! final aggregate result — no raw document bytes are retained.  Memory per
//! group is O(num_aggregates × accumulator_size) regardless of how many
//! documents match that group.
//!
//! Module split:
//! - `state` — `AggAccum` / `GroupState` type definitions + `GroupState` impl.
//! - `new` — `AggAccum::new`.
//! - `feed` — `AggAccum::feed` (folds one document in).
//! - `finalize` — `AggAccum::finalize` (produces the result `Value`).
//! - `merge` — `merge_accum` / `merge_group_state` for spilled-run merge.

mod feed;
mod finalize;
mod merge;
mod new;
mod state;

#[cfg(test)]
mod tests;

pub(crate) use state::GroupState;