Function mz_storage::render::sources::upsert_commands

source ยท 
fn upsert_commands<G: Scope, FromTime: Timestamp>(
    input: Collection<G, DecodeResult<FromTime>, Diff>,
    upsert_envelope: UpsertEnvelope,
) -> Collection<G, (UpsertKey, Option<Result<Row, UpsertError>>, FromTime), Diff>
Expand description

Convert from streams of DecodeResult to UpsertCommands, inserting the Key according to KeyEnvelope