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