Function read_avro_schema_from_reader

datafusion/datasource-avro/src/mod.rs:41–50

Read Avro schema given a reader

(
    reader: &mut R,
)

/// Read Avro schema given a reader
pub fn read_avro_schema_from_reader<R: Read>(
    reader: &mut R,
) -> datafusion_common::Result<Schema> {
    let avro_reader = ReaderBuilder::new().build(BufReader::new(reader))?;
    // Avro readers perform strict schema resolution rules (e.g. record identity checks)
    // that are stricter than DataFusion's table schema handling needs for inferred schemas.
    // Drop metadata from inferred schemas so runtime batches and inferred table schemas
    // compare consistently without requiring strict Avro metadata identity.
    Ok(strip_metadata_from_schema(avro_reader.schema().as_ref()))
}

fn strip_metadata_from_schema(schema: &Schema) -> Schema {
    let fields = schema