laminar_core/aggregation/mod.rs
1//! # Cross-Partition Aggregation Module
2//!
3//! Lock-free data structures for aggregating state across partitions
4//! in a partition-parallel system.
5//!
6//! ## Module Overview
7//!
8//! - `cross_partition`: Concurrent partial aggregate store backed by `papaya::HashMap`
9//! - `two_phase`: Two-phase aggregation (partial per partition → merge on coordinator)
10
11/// Lock-free cross-partition aggregate store.
12pub mod cross_partition;
13/// Gossip-based partial aggregate replication across nodes.
14#[cfg(feature = "delta")]
15pub mod gossip_aggregates;
16/// Two-phase cross-partition aggregation.
17pub mod two_phase;
18
19pub use cross_partition::CrossPartitionAggregateStore;