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.

Functions