pub fn render_decode_chunk<G, F>(
scope: G,
format: F,
record_chunks: &Stream<G, Result<F::RecordChunk, StorageErrorX>>,
) -> (Stream<G, Result<Row, StorageErrorX>>, PressOnDropButton)where
G: Scope,
F: OneshotFormat + 'static,
Expand description
Render an operator that given a stream of OneshotFormat::RecordChunk
s will decode these
chunks into a stream of Row
s.