oxirs-stream 0.3.1

Real-time streaming support with Kafka/NATS/MQTT/OPC-UA I/O, RDF Patch, and SPARQL Update delta
Documentation
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
//! # 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.

pub mod exactly_once;

pub use exactly_once::{
    ExactlyOnceAggregator, ExactlyOnceAggregatorConfig, ExactlyOnceAggregatorStats,
    PartitionAggregateState, PartitionAggregateValue,
};