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>, Option<usize>)
Expand description

Get the indices of the split, offset, and pulsar message id columns.