Module persist::operators [−][src]
Expand description
Timely and Differential Dataflow operators for persisting and replaying data.
Modules
A Timely Dataflow operator that synchronously persists stream input.
A Timely Dataflow operator that emits the records in a snapshot.
A Timely Dataflow operator that mirrors a persisted stream.
Modular Timely Dataflow operators that can persist and seal updates in streams.
A Timely Dataflow operator that turns a stream of keyed upserts into a stream of differential updates.