mz_storage_operators::oneshot_source

Function render_decode_chunk

Source
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::RecordChunks will decode these chunks into a stream of Rows.