risingwave_connector_codec::decoder::avro

Function avro_schema_to_column_descs

source 
pub fn avro_schema_to_column_descs(
    schema: &Schema,
    map_handling: Option<MapHandling>,
) -> Result<Vec<ColumnDesc>>
Expand description

This function expects original schema (with Ref). TODO: change map_handling to some Config, and also unify debezium. TODO: use ColumnDesc in common instead of PB.