Function mz_storage::upsert::stage_input

source ยท 
fn stage_input<T, FromTime>(
    stash: &mut Vec<(T, UpsertKey, Reverse<FromTime>, Option<Result<Row, UpsertError>>)>,
    data: &mut Vec<((UpsertKey, Option<Result<Row, UpsertError>>, FromTime), T, Diff)>,
    input_upper: &Antichain<T>,
    resume_upper: &Antichain<T>,
    storage_shrink_upsert_unused_buffers_by_ratio: usize,
)
where
    T: PartialOrder,
    FromTime: Ord,
Expand description

Helper method for upsert_classic used to stage data updates from the input/source timely edge.