oxirs_stream/aggregation/mod.rs
1//! # Watermark- and exactly-once-aware aggregation operators
2//!
3//! Complements the wall-clock based aggregation in
4//! [`crate::processing::aggregation`] with operators that integrate with
5//! the operator-parallelism + checkpointing model:
6//!
7//! * [`exactly_once::ExactlyOnceAggregator`] — wraps a per-partition
8//! aggregation state with the deduplication / transaction primitives in
9//! [`crate::state::exactly_once`] so that re-deliveries do not double-count.
10
11pub mod exactly_once;
12
13pub use exactly_once::{
14 ExactlyOnceAggregator, ExactlyOnceAggregatorConfig, ExactlyOnceAggregatorStats,
15 PartitionAggregateState, PartitionAggregateValue,
16};