risingwave_stream::executor::source::source_executor

Function extract_split_offset

Source 
fn extract_split_offset(split: &SplitImpl) -> Option<u64>
Expand description

Extract offset value from CDC split

This function extracts the offset value from CDC split. For Postgres CDC, the offset is LSN.