Function mz_storage::render::upsert::process_new_data

fn process_new_data(
    new_data: &mut Vec<(((Option<Result<Row, UpsertError>>, Option<Result<Row, UpsertError>>), MzOffset, Row), Timestamp, Diff)>,
    pending_values: &mut BTreeMap<Timestamp, (Capability<Timestamp>, BTreeMap<Option<Result<Row, UpsertError>>, UpsertSourceData>)>,
    cap: &InputCapability<Timestamp>,
    as_of_frontier: &Antichain<Timestamp>
)

This function fills pending_values with new data from the timely operator input.

The given tuple contains key, value, a “position”, and “metadata”.