Rename function

src/io/avro/read/mod.rs

@@ -17,7 +17,7 @@ mod schema;
 mod util;
 
 pub(super) use header::deserialize_header;
-pub(super) use schema::convert_schema;
+pub(super) use schema::infer_schema;
 
 use crate::array::Array;
 use crate::chunk::Chunk;
@@ -32,7 +32,7 @@ pub fn read_metadata<R: std::io::Read>(
     reader: &mut R,
 ) -> Result<(Vec<AvroSchema>, Schema, Option<Compression>, [u8; 16])> {
     let (avro_schema, codec, marker) = util::read_schema(reader)?;
-    let schema = convert_schema(&avro_schema)?;
+    let schema = infer_schema(&avro_schema)?;
 
     let avro_schema = if let AvroSchema::Record(Record { fields, .. }) = avro_schema {
         fields.into_iter().map(|x| x.schema).collect()

src/io/avro/read/schema.rs

@@ -19,8 +19,9 @@ fn external_props(schema: &AvroSchema) -> Metadata {
     props
 }
 
-/// Maps an [`AvroSchema`] into a [`Schema`].
-pub fn convert_schema(schema: &AvroSchema) -> Result<Schema> {
+/// Infers an [`Schema`] from the root [`AvroSchema`].
+/// This
+pub fn infer_schema(schema: &AvroSchema) -> Result<Schema> {
     if let AvroSchema::Record(Record { fields, .. }) = schema {
         Ok(fields
             .iter()
@@ -35,7 +36,7 @@ pub fn convert_schema(schema: &AvroSchema) -> Result<Schema> {
             .into())
     } else {
         Err(ArrowError::OutOfSpec(
-            "An avro Schema must be of type Record".to_string(),
+            "The root AvroSchema must be of type Record".to_string(),
         ))
     }
 }

src/io/avro/read_async/metadata.rs

@@ -8,8 +8,8 @@ use futures::AsyncReadExt;
 use crate::datatypes::Schema;
 use crate::error::{ArrowError, Result};
 
-use super::super::read::convert_schema;
 use super::super::read::deserialize_header;
+use super::super::read::infer_schema;
 use super::super::Compression;
 use super::super::{read_header, read_metadata};
 use super::utils::zigzag_i64;
@@ -28,7 +28,7 @@ pub async fn read_metadata<R: AsyncRead + Unpin + Send>(
     reader: &mut R,
 ) -> Result<(Vec<AvroSchema>, Schema, Option<Compression>, [u8; 16])> {
     let (avro_schema, codec, marker) = read_metadata_async(reader).await?;
-    let schema = convert_schema(&avro_schema)?;
+    let schema = infer_schema(&avro_schema)?;
 
     let avro_schema = if let AvroSchema::Record(Record { fields, .. }) = avro_schema {
         fields.into_iter().map(|x| x.schema).collect()