risingwave_frontend::handler::create_connection

Function resolve_create_connection_payload

source 
fn resolve_create_connection_payload(
    with_properties: &BTreeMap<String, String>,
) -> Result<Payload, RwError>