fmt

apache · Jan 24, 2024 · 6a9d76b · 6a9d76b
1 parent d8d327a
commit 6a9d76b
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git a/datafusion/core/src/datasource/physical_plan/parquet/mod.rs b/datafusion/core/src/datasource/physical_plan/parquet/mod.rs
@@ -787,7 +787,7 @@ mod tests {
         array::{Int64Array, Int8Array, StringArray},
         datatypes::{DataType, Field, SchemaBuilder},
     };
-        use arrow_array::{Date64Array, StructArray};
+    use arrow_array::{Date64Array, StructArray};
     use arrow_schema::Fields;
     use chrono::{TimeZone, Utc};
     use datafusion_common::{assert_contains, ToDFSchema};

diff --git a/datafusion/core/src/datasource/physical_plan/parquet/page_filter.rs b/datafusion/core/src/datasource/physical_plan/parquet/page_filter.rs
@@ -255,7 +255,7 @@ impl PagePruningPredicate {
 fn find_column_index(
     predicate: &PruningPredicate,
     arrow_schema: &Schema,
-    parquet_schema: &SchemaDescriptor
+    parquet_schema: &SchemaDescriptor,
 ) -> Option<usize> {
     let mut found_required_column: Option<&Column> = None;
 
@@ -278,8 +278,7 @@ fn find_column_index(
         return None;
     };
 
-    parquet_column(parquet_schema, arrow_schema, column.name())
-        .map(|x| x.0)
+    parquet_column(parquet_schema, arrow_schema, column.name()).map(|x| x.0)
 }
 
 /// Intersects the [`RowSelector`]s