Skip to main content

mark_cdc_chunk_inner

risingwave_stream::executor::backfill::utils

Function mark_cdc_chunk_inner 

Source 
fn mark_cdc_chunk_inner(
    offset_parse_func: &CdcOffsetParseFunc,
    chunk: StreamChunk,
    current_pos: &OwnedRow,
    last_cdc_offset: Option<CdcOffset>,
    pk_in_output_indices: &[usize],
    pk_order: &[OrderType],
    pk_needs_unsigned_i64_compare: &[bool],
) -> StreamExecutorResult<StreamChunk>