mz_storage::upsert

Function drain_staged_input

Source
async fn drain_staged_input<S, G, T, FromTime, E>(
    stash: &mut Vec<(T, UpsertKey, Reverse<FromTime>, Option<Result<Row, UpsertError>>)>,
    commands_state: &mut IndexMap<UpsertKey, UpsertValueAndSize<Option<FromTime>>>,
    output_updates: &mut Vec<(Result<Row, UpsertError>, T, Diff)>,
    multi_get_scratch: &mut Vec<UpsertKey>,
    drain_style: DrainStyle<'_, T>,
    error_emitter: &mut E,
    state: &mut UpsertState<'_, S, Option<FromTime>>,
)
where S: UpsertStateBackend<Option<FromTime>>, G: Scope, T: PartialOrder + Ord + Clone + Debug, FromTime: ExchangeData + Ord, E: UpsertErrorEmitter<G>,
Expand description

Helper method for upsert_inner used to stage data updates from the input timely edge.