risingwave_frontend::handler::create_connection

Function resolve_create_connection_payload

Source 
fn resolve_create_connection_payload(
    with_properties: WithOptions,
    session: &SessionImpl,
) -> Result<Payload>