Function dataflow::render::sources::flatten_results_prepend_keys [−][src]
fn flatten_results_prepend_keys<G>(
key_envelope: &KeyEnvelope,
results: Stream<G, KV>
) -> Stream<G, Result<Row, DecodeError>> where
G: Scope<Timestamp = Timestamp>,
Expand description
Convert from streams of DecodeResult
to Rows, inserting the Key according to KeyEnvelope