risingwave_stream::executor::backfill::utils

Function get_new_pos

source
pub(crate) fn get_new_pos(
    chunk: &StreamChunk,
    pk_in_output_indices: &[usize],
) -> OwnedRow
Expand description

Get new backfill pos from the chunk. Since chunk should have ordered rows, we can just take the last row.