Module aggregation 

Watermark- and exactly-once-aware aggregation operators

Complements the wall-clock based aggregation in crate::processing::aggregation with operators that integrate with the operator-parallelism + checkpointing model:

• exactly_once::ExactlyOnceAggregator — wraps a per-partition aggregation state with the deduplication / transaction primitives in crate::state::exactly_once so that re-deliveries do not double-count.

Re-exports

pub use exactly_once::ExactlyOnceAggregator;

pub use exactly_once::ExactlyOnceAggregatorConfig;

pub use exactly_once::ExactlyOnceAggregatorStats;

pub use exactly_once::PartitionAggregateState;

pub use exactly_once::PartitionAggregateValue;

Modules

exactly_once

Exactly-once aggregation under operator parallelism.