Skip to main content

laminar_connectors/changelog/
mod.rs

1//! Sink-agnostic changelog collapse for upsert sinks. A commit epoch can carry
2//! many changelog events for one merge key (every aggregate value change is a
3//! retract + insert), which an upsert writer rejects as a cardinality
4//! violation. `collapse_changelog` folds an epoch down to one row per key.
5
6mod collapse;
7
8pub use collapse::collapse_changelog;