mz_catalog::durable::persist

Function snapshot_binary_inner

Source
async fn snapshot_binary_inner(
    read_handle: &mut ReadHandle<SourceData, (), Timestamp, Diff>,
    as_of: Timestamp,
) -> impl Iterator<Item = StateUpdate<StateUpdateKindJson>> + DoubleEndedIterator
Expand description

Generates an iterator of StateUpdate that contain all updates to the catalog state up to, and including, as_of.

The output is consolidated and sorted by timestamp in ascending order.