risingwave_frontend::handler::create_source

Function extract_avro_table_schema

source 
async fn extract_avro_table_schema(
    info: &StreamSourceInfo,
    with_properties: &WithOptionsSecResolved,
    format_encode_options: &mut BTreeMap<String, String>,
    is_debezium: bool,
) -> Result<Vec<ColumnCatalog>, RwError>
Expand description

Map an Avro schema to a relational schema.