Skip to main content

as_recorded_updates

Function as_recorded_updates 

Source
pub fn as_recorded_updates<U>(
    arranged: Arranged<'_, TraceAgent<ValSpine<U::Key, U::Val, U::Time, U::Diff>>>,
) -> Collection<'_, U::Time, RecordedUpdates<U>>
where U: ColumnarUpdate,
Expand description

Extract a Collection<_, RecordedUpdates<U>> from a columnar Arranged.

Cursors through each batch and pushes (key, val, time, diff) refs into a ValColBuilder, which sorts and consolidates on flush.