Skip to main content

flush_through

mz_storage::upsert_continual_feedback_v2::stash

Function flush_through 

Source 
fn flush_through<T, O, U, C>(
    updates: &mut Vec<(UpsertKey, T, UpsertDiff<O>)>,
    chunker: &mut C,
    record: impl FnMut((UpsertKey, T, UpsertDiff<O>), &mut Column<U>),
    push: impl FnMut(C::Container),
)
where
    U: Columnar,
    C: ContainerBuilder + for<'a> PushInto<&'a mut Column<U>>,
    C::Container: Default,
Expand description

The shared body of the arms’ flush: writes each update into a raw column through record, consolidates it through chunker, and hands each readied chunk to push.