From db80c4ce87c1fa1d92cc04135cdbfaa8fb1d5158 Mon Sep 17 00:00:00 2001
From: "Jorge C. Leitao" <jorgecarleitao@gmail.com>
Date: Mon, 20 Dec 2021 07:18:13 +0000
Subject: [PATCH] Clippy

---
 examples/parquet_read.rs    | 2 +-
 src/io/avro/write/block.rs  | 3 +--
 src/io/avro/write/schema.rs | 8 ++------
 tests/it/io/avro/read.rs    | 2 +-
 4 files changed, 5 insertions(+), 10 deletions(-)

diff --git a/examples/parquet_read.rs b/examples/parquet_read.rs
index 8d37d83ec6c..5435ae34703 100644
--- a/examples/parquet_read.rs
+++ b/examples/parquet_read.rs
@@ -41,6 +41,6 @@ fn main() -> Result<()> {
     let row_group = args[3].parse::<usize>().unwrap();
 
     let array = read_field(file_path, row_group, field)?;
-    println!("{}", array);
+    println!("{:?}", array);
     Ok(())
 }
diff --git a/src/io/avro/write/block.rs b/src/io/avro/write/block.rs
index 9251ca24448..562019f6c56 100644
--- a/src/io/avro/write/block.rs
+++ b/src/io/avro/write/block.rs
@@ -61,10 +61,9 @@ pub fn compress(
     compressed_block: &mut CompressedBlock,
     compression: Compression,
 ) -> Result<()> {
+    compressed_block.number_of_rows = block.number_of_rows;
     match compression {
         Compression::Deflate => todo!(),
         Compression::Snappy => todo!(),
     }
-    compressed_block.number_of_rows = block.number_of_rows;
-    Ok(())
 }
diff --git a/src/io/avro/write/schema.rs b/src/io/avro/write/schema.rs
index fdee06a1ede..b8cb5917a10 100644
--- a/src/io/avro/write/schema.rs
+++ b/src/io/avro/write/schema.rs
@@ -5,13 +5,9 @@ use avro_schema::{
 use crate::datatypes::*;
 use crate::error::{ArrowError, Result};
 
-/// Converts a [`Schema`] to an avro [`AvroSchema::Record`] with it.
+/// Converts a [`Schema`] to a vector of [`AvroField`] with it.
 pub fn to_avro_schema(schema: &Schema) -> Result<Vec<AvroField>> {
-    schema
-        .fields
-        .iter()
-        .map(|field| field_to_field(field))
-        .collect()
+    schema.fields.iter().map(field_to_field).collect()
 }
 
 fn field_to_field(field: &Field) -> Result<AvroField> {
diff --git a/tests/it/io/avro/read.rs b/tests/it/io/avro/read.rs
index ba58a6901fe..d55e10332d3 100644
--- a/tests/it/io/avro/read.rs
+++ b/tests/it/io/avro/read.rs
@@ -98,7 +98,7 @@ pub(super) fn data() -> RecordBatch {
 }
 
 pub(super) fn write_avro(codec: Codec) -> std::result::Result<Vec<u8>, avro_rs::Error> {
-    let (avro, schema) = schema();
+    let (avro, _) = schema();
     // a writer needs a schema and something to write to
     let mut writer = Writer::with_codec(&avro, Vec::new(), codec);