risingwave_connector::sink::mqtt

Function get_topic_from_index_path

source
fn get_topic_from_index_path<'s>(
    path: &[usize],
    default_topic: Option<&'s str>,
    row: &'s RowRef<'s>,
) -> Option<&'s str>