File tree Expand file tree Collapse file tree 1 file changed +12
-2
lines changed
datafusion/core/src/datasource/physical_plan Expand file tree Collapse file tree 1 file changed +12
-2
lines changed Original file line number Diff line number Diff line change @@ -897,7 +897,12 @@ mod tests {
897
897
let metrics = rt. parquet_exec . metrics ( ) . unwrap ( ) ;
898
898
assert_eq ! ( get_value( & metrics, "predicate_evaluation_errors" ) , 0 ) ;
899
899
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 > ( ) ;
901
906
assert_eq ! ( read, 2 , "Expected 2 rows to match the predicate" ) ;
902
907
}
903
908
@@ -932,7 +937,12 @@ mod tests {
932
937
// There should be no predicate evaluation errors
933
938
let metrics = rt. parquet_exec . metrics ( ) . unwrap ( ) ;
934
939
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 > ( ) ;
936
946
assert_eq ! ( read, 2 , "Expected 2 rows to match the predicate" ) ;
937
947
}
938
948
You can’t perform that action at this time.
0 commit comments