risingwave_connector::parser::debezium::avro_parser

Function extract_debezium_table_schema

Source 
fn extract_debezium_table_schema(root: &Schema) -> Result<&Schema>