From ab0485612060444305e2053f0a5d18805514f9e6 Mon Sep 17 00:00:00 2001
From: Jay Chia <jaychia94@gmail.com@users.noreply.github.com>
Date: Tue, 5 Sep 2023 13:54:58 -0700
Subject: [PATCH] fmt and lints

---
 src/io/parquet/read/deserialize/simple.rs | 28 ++++++++++-------------
 src/io/parquet/read/schema/convert.rs     |  8 +++++--
 2 files changed, 18 insertions(+), 18 deletions(-)

diff --git a/src/io/parquet/read/deserialize/simple.rs b/src/io/parquet/read/deserialize/simple.rs
index 299f339a90..15cbca10b9 100644
--- a/src/io/parquet/read/deserialize/simple.rs
+++ b/src/io/parquet/read/deserialize/simple.rs
@@ -8,7 +8,7 @@ use parquet2::{
 
 use crate::types::i256;
 use crate::{
-    array::{Array, DictionaryKey, MutablePrimitiveArray, PrimitiveArray, BinaryArray},
+    array::{Array, BinaryArray, DictionaryKey, MutablePrimitiveArray, PrimitiveArray},
     datatypes::{DataType, IntervalUnit, TimeUnit},
     error::{Error, Result},
     types::{days_ms, NativeType},
@@ -231,26 +231,22 @@ pub fn page_iter_to_arrays<'a, I: Pages + 'a>(
             Box::new(arrays) as _
         }
         (PhysicalType::ByteArray, Decimal(_, _)) => {
-            let pages = binary::Iter::<i32, _>::new(
-                pages,
-                DataType::Binary,
-                chunk_size,
-                num_rows,
-            );
+            let pages = binary::Iter::<i32, _>::new(pages, DataType::Binary, chunk_size, num_rows);
 
             let pages = pages.map(move |maybe_array| {
                 let array = maybe_array?;
                 let array_len = array.len();
                 let array = array.as_any().downcast_ref::<BinaryArray<i32>>().unwrap();
-                let values = (0..array_len).map(|i| {
-                    let value = array.value(i);
-                    let n = value.len();
-                    if n > 16 {
-                        return Err(Error::Overflow);
-                    }
-                    Ok(super::super::convert_i128(value, n))
-                })
-                .collect::<Result<Vec<_>>>();
+                let values = (0..array_len)
+                    .map(|i| {
+                        let value = array.value(i);
+                        let n = value.len();
+                        if n > 16 {
+                            return Err(Error::Overflow);
+                        }
+                        Ok(super::super::convert_i128(value, n))
+                    })
+                    .collect::<Result<Vec<_>>>();
                 let validity = array.validity().cloned();
 
                 PrimitiveArray::<i128>::try_new(data_type.clone(), values?.into(), validity)
diff --git a/src/io/parquet/read/schema/convert.rs b/src/io/parquet/read/schema/convert.rs
index a8ea3dc392..ef3786c1e9 100644
--- a/src/io/parquet/read/schema/convert.rs
+++ b/src/io/parquet/read/schema/convert.rs
@@ -142,8 +142,12 @@ fn from_byte_array(
         (_, Some(PrimitiveConvertedType::Bson)) => DataType::Binary,
         (_, Some(PrimitiveConvertedType::Enum)) => DataType::Binary,
         (_, Some(PrimitiveConvertedType::Utf8)) => DataType::Utf8,
-        (Some(PrimitiveLogicalType::Decimal(precision, scale)), _) => DataType::Decimal(*precision, *scale),
-        (_, Some(PrimitiveConvertedType::Decimal(precision, scale))) => DataType::Decimal(*precision, *scale),
+        (Some(PrimitiveLogicalType::Decimal(precision, scale)), _) => {
+            DataType::Decimal(*precision, *scale)
+        }
+        (_, Some(PrimitiveConvertedType::Decimal(precision, scale))) => {
+            DataType::Decimal(*precision, *scale)
+        }
         (_, _) => DataType::Binary,
     }
 }