risingwave_connector::parser

Function fetch_json_schema_and_map_to_columns

source
pub async fn fetch_json_schema_and_map_to_columns(
    schema_location: &str,
    schema_registry_auth: Option<SchemaRegistryAuth>,
    props: &BTreeMap<String, String>,
) -> ConnectorResult<Vec<ColumnDesc>>