avro_schema_to_fields

risingwave_connector_codec::decoder::avro::schema

Function avro_schema_to_fields 

Source 
pub fn avro_schema_to_fields(
    schema: &Schema,
    map_handling: Option<MapHandling>,
) -> Result<Vec<Field>>
Expand description

This function expects original schema (with Ref). TODO: change map_handling to some Config, and also unify debezium.