File tree 1 file changed +4
-8
lines changed
datafusion/core/src/physical_plan/file_format 1 file changed +4
-8
lines changed Original file line number Diff line number Diff line change @@ -959,7 +959,7 @@ mod tests {
959
959
let file_groups = meta. into_iter ( ) . map ( Into :: into) . collect ( ) ;
960
960
961
961
// prepare the scan
962
- let mut parquet_exec = ParquetExec :: new (
962
+ let parquet_exec = ParquetExec :: new (
963
963
FileScanConfig {
964
964
object_store_url : ObjectStoreUrl :: local_filesystem ( ) ,
965
965
file_groups : vec ! [ file_groups] ,
@@ -972,13 +972,9 @@ mod tests {
972
972
} ,
973
973
predicate,
974
974
None ,
975
- ) ;
976
-
977
- if pushdown_predicate {
978
- parquet_exec = parquet_exec
979
- . with_pushdown_filters ( true )
980
- . with_reorder_filters ( true ) ;
981
- }
975
+ )
976
+ . with_pushdown_filters ( pushdown_predicate)
977
+ . with_reorder_filters ( pushdown_predicate) ;
982
978
983
979
let session_ctx = SessionContext :: new ( ) ;
984
980
let task_ctx = session_ctx. task_ctx ( ) ;
You can’t perform that action at this time.
0 commit comments