risingwave_stream::executor::backfill::utils

Function update_pos_by_vnode

source 
pub(crate) fn update_pos_by_vnode(
    vnode: VirtualNode,
    chunk: &StreamChunk,
    pk_in_output_indices: &[usize],
    backfill_state: &mut BackfillState,
    snapshot_row_count_delta: u64,
) -> StreamExecutorResult<()>
Expand description

Update backfill pos by vnode.