Skip to main content

Module aggregate

Module aggregate 

Source
Expand description

Zero-deserialization aggregate computation on raw MessagePack documents.

Replaces compute_aggregate(op, field, docs: &[serde_json::Value]) with direct binary field extraction. Each document is &[u8] (MessagePack map). When an expression is provided, decodes msgpack → nodedb_types::Value directly (no JSON intermediate) and evaluates the expression once per document.

Functions§

compute_aggregate_binary
Compute an aggregate function over raw MessagePack documents.