Module persist::operators::upsert [−][src]
Expand description
A Timely Dataflow operator that turns a stream of keyed upserts into a stream of differential updates.
Structs
Ingests differential updates, consolidates them, and emits a final HashMap that contains the
consolidated upsert state.
Persist configuration for persistent upsert.
Traits
Extension trait for Stream.