risingwave_stream::executor::source

Function get_split_offset_col_idx

source 
pub fn get_split_offset_col_idx(
    column_descs: &[SourceColumnDesc],
) -> (Option<usize>, Option<usize>)