mz_storage::render::sources

Function 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