risingwave_stream::executor::backfill::snapshot_backfill

Function read_change_log

source 
fn read_change_log(
    stream: impl Stream<Item = StorageResult<ChangeLogRow>>,
    builder: DataChunkBuilder,
) -> impl Stream<Item = Result<StreamChunk, StreamExecutorError>>