risingwave_stream::executor::backfill::snapshot_backfill

Function make_snapshot_stream

source 
fn make_snapshot_stream<'a>(
    row_stream: impl Stream<Item = StreamExecutorResult<OwnedRow>> + 'a,
    builder: DataChunkBuilder,
    output_indices: &'a [usize],
) -> impl Stream<Item = Result<StreamChunk, StreamExecutorError>> + 'a