fix rustfmt issues

apache · Jun 9, 2021 · d5173db · d5173db
1 parent 9ebf874
commit d5173db
Show file tree

Hide file tree

Showing 8 changed files with 869 additions and 415 deletions.
diff --git a/arrow/src/array/transform/mod.rs b/arrow/src/array/transform/mod.rs
@@ -25,7 +25,7 @@ use std::mem;
 
 use super::{
     data::{into_buffers, new_buffers},
-    ArrayData, ArrayDataBuilder
+    ArrayData, ArrayDataBuilder,
 };
 use crate::array::StringOffsetSizeTrait;
 
@@ -84,7 +84,8 @@ impl<'a> _MutableArrayData<'a> {
             .buffers(buffers)
             .child_data(child_data);
         if self.null_count > 0 {
-            array_data_builder = array_data_builder.null_bit_buffer(self.null_buffer.into());
+            array_data_builder =
+                array_data_builder.null_bit_buffer(self.null_buffer.into());
         }
 
         array_data_builder
@@ -554,8 +555,7 @@ impl<'a> MutableArrayData<'a> {
         let null_buffer = if use_nulls {
             let null_bytes = bit_util::ceil(array_capacity, 8);
             MutableBuffer::from_len_zeroed(null_bytes)
-        }
-        else {
+        } else {
             // create 0 capacity mutable buffer with the intention that it won't be used
             MutableBuffer::with_capacity(0)
         };

diff --git a/parquet/benches/arrow_array_reader.rs b/parquet/benches/arrow_array_reader.rs
diff --git a/parquet/src/arrow/array_reader.rs b/parquet/src/arrow/array_reader.rs
@@ -1499,7 +1499,9 @@ impl<'a> ArrayReaderBuilder {
                             arrow_type,
                         )?))
                     } else {
-                        use crate::arrow::arrow_array_reader::{StringArrayConverter, ArrowArrayReader};
+                        use crate::arrow::arrow_array_reader::{
+                            ArrowArrayReader, StringArrayConverter,
+                        };
                         let converter = StringArrayConverter::new();
                         Ok(Box::new(ArrowArrayReader::try_new(
                             *page_iterator,

diff --git a/parquet/src/arrow/arrow_array_reader.rs b/parquet/src/arrow/arrow_array_reader.rs
diff --git a/parquet/src/arrow/record_reader.rs b/parquet/src/arrow/record_reader.rs
@@ -466,7 +466,7 @@ mod tests {
 
     impl Iterator for TestPageReader {
         type Item = Result<Page>;
-    
+
         fn next(&mut self) -> Option<Self::Item> {
             self.get_next_page().transpose()
         }

diff --git a/parquet/src/column/reader.rs b/parquet/src/column/reader.rs
@@ -1356,7 +1356,7 @@ mod tests {
 
     impl Iterator for TestPageReader {
         type Item = Result<Page>;
-    
+
         fn next(&mut self) -> Option<Self::Item> {
             self.get_next_page().transpose()
         }

diff --git a/parquet/src/util/mod.rs b/parquet/src/util/mod.rs
@@ -23,4 +23,6 @@ mod bit_packing;
 pub mod cursor;
 pub mod hash_util;
 pub(crate) mod test_common;
-pub use self::test_common::page_util::{InMemoryPageIterator, DataPageBuilderImpl, DataPageBuilder};
+pub use self::test_common::page_util::{
+    DataPageBuilder, DataPageBuilderImpl, InMemoryPageIterator,
+};
diff --git a/parquet/src/util/test_common/page_util.rs b/parquet/src/util/test_common/page_util.rs
@@ -217,9 +217,9 @@ impl<I: Iterator<Item = Vec<Page>>> Iterator for InMemoryPageIterator<I> {
     type Item = Result<Box<dyn PageReader>>;
 
     fn next(&mut self) -> Option<Self::Item> {
-        self.page_reader_iter.next().map(
-            |x| Ok(Box::new(InMemoryPageReader::new(x)) as Box<dyn PageReader>)
-        )
+        self.page_reader_iter
+            .next()
+            .map(|x| Ok(Box::new(InMemoryPageReader::new(x)) as Box<dyn PageReader>))
     }
 }