Function mz_storage::render::sources::flatten_results_prepend_keys

source ยท 
fn flatten_results_prepend_keys<G>(
    none_envelope: &NoneEnvelope,
    results: Collection<G, KV, Diff>,
) -> Collection<G, Result<Row, DataflowError>, Diff>
where
    G: Scope,
Expand description

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