risingwave_stream::executor::backfill::utils

Function get_cdc_chunk_last_offset

source 
pub(crate) fn get_cdc_chunk_last_offset(
    offset_parse_func: &CdcOffsetParseFunc,
    chunk: &StreamChunk,
) -> StreamExecutorResult<Option<CdcOffset>>