get_split_offset_col_idx

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>)