File tree Expand file tree Collapse file tree
datafusion/core/src/datasource/physical_plan Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -897,7 +897,12 @@ mod tests {
897897 let metrics = rt. parquet_exec . metrics ( ) . unwrap ( ) ;
898898 assert_eq ! ( get_value( & metrics, "predicate_evaluation_errors" ) , 0 ) ;
899899 assert_eq ! ( get_value( & metrics, "pushdown_rows_matched" ) , 0 ) ;
900- let read = rt. batches . unwrap ( ) . iter ( ) . map ( |b| b. num_rows ( ) ) . sum :: < usize > ( ) ;
900+ let read = rt
901+ . batches
902+ . unwrap ( )
903+ . iter ( )
904+ . map ( |b| b. num_rows ( ) )
905+ . sum :: < usize > ( ) ;
901906 assert_eq ! ( read, 2 , "Expected 2 rows to match the predicate" ) ;
902907 }
903908
@@ -932,7 +937,12 @@ mod tests {
932937 // There should be no predicate evaluation errors
933938 let metrics = rt. parquet_exec . metrics ( ) . unwrap ( ) ;
934939 assert_eq ! ( get_value( & metrics, "predicate_evaluation_errors" ) , 0 ) ;
935- let read = rt. batches . unwrap ( ) . iter ( ) . map ( |b| b. num_rows ( ) ) . sum :: < usize > ( ) ;
940+ let read = rt
941+ . batches
942+ . unwrap ( )
943+ . iter ( )
944+ . map ( |b| b. num_rows ( ) )
945+ . sum :: < usize > ( ) ;
936946 assert_eq ! ( read, 2 , "Expected 2 rows to match the predicate" ) ;
937947 }
938948
You can’t perform that action at this time.
0 commit comments