fmt

Author: adriangb

datafusion/datasource-parquet/src/opener.rs

@@ -25,7 +25,8 @@ use crate::file_format::{
 use crate::page_filter::PagePruningAccessPlanFilter;
 use crate::row_group_filter::RowGroupAccessPlanFilter;
 use crate::{
-    row_filter, should_enable_page_index, ParquetAccessPlan, ParquetFileMetrics, ParquetFileReaderFactory
+    row_filter, should_enable_page_index, ParquetAccessPlan, ParquetFileMetrics,
+    ParquetFileReaderFactory,
 };
 use datafusion_datasource::file_expr_rewriter::FileExpressionRewriter;
 use datafusion_datasource::file_meta::FileMeta;
@@ -173,17 +174,17 @@ impl FileOpener for ParquetOpener {
                 adapted_projections.iter().cloned(),
             );
 
-
             // Try to rewrite the predicate using our filter expression rewriter
             // This must happen before build_row_filter and other subsequent steps
             // so that they all use the rewritten predicate if it was rewritten.
             if let Some(original_predicate) = predicate.clone() {
                 if let Some(filter_rewriter) = filter_expression_rewriter_factory {
-                    if let Ok(rewritten) =
-                        filter_rewriter.rewrite(Arc::clone(&file_schema), original_predicate)
+                    if let Ok(rewritten) = filter_rewriter
+                        .rewrite(Arc::clone(&file_schema), original_predicate)
                     {
                         // If we rewrote the filter we need to recompute the pruning predicates to match the new filter.
-                        page_pruning_predicate = Some(build_page_pruning_predicate(&rewritten, &file_schema));
+                        page_pruning_predicate =
+                            Some(build_page_pruning_predicate(&rewritten, &file_schema));
                         pruning_predicate = build_pruning_predicate(
                             rewritten.clone(),
                             &file_schema,

datafusion/datasource-parquet/src/source.rs

@@ -321,8 +321,10 @@ impl ParquetSource {
         conf.with_metrics(metrics);
         conf.predicate = Some(Arc::clone(&predicate));
 
-        conf.page_pruning_predicate = Some(build_page_pruning_predicate(&predicate, &file_schema));
-        conf.pruning_predicate = build_pruning_predicate(predicate, &file_schema, &predicate_creation_errors);
+        conf.page_pruning_predicate =
+            Some(build_page_pruning_predicate(&predicate, &file_schema));
+        conf.pruning_predicate =
+            build_pruning_predicate(predicate, &file_schema, &predicate_creation_errors);
 
         conf
     }