risingwave_stream::from_proto::source

Function get_connector_name

Source 
fn get_connector_name(with_props: &BTreeMap<String, String>) -> String