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 @@ -986,7 +986,7 @@ mod tests {
986
986
let file_groups = meta. into_iter ( ) . map ( Into :: into) . collect ( ) ;
987
987
988
988
// prepare the scan
989
- let mut parquet_exec = ParquetExec :: new (
989
+ let parquet_exec = ParquetExec :: new (
990
990
FileScanConfig {
991
991
object_store_url : ObjectStoreUrl :: local_filesystem ( ) ,
992
992
file_groups : vec ! [ file_groups] ,
@@ -999,13 +999,9 @@ mod tests {
999
999
} ,
1000
1000
predicate,
1001
1001
None ,
1002
- ) ;
1003
-
1004
- if pushdown_predicate {
1005
- parquet_exec = parquet_exec
1006
- . with_pushdown_filters ( true )
1007
- . with_reorder_filters ( true ) ;
1008
- }
1002
+ )
1003
+ . with_pushdown_filters ( pushdown_predicate)
1004
+ . with_reorder_filters ( pushdown_predicate) ;
1009
1005
1010
1006
let session_ctx = SessionContext :: new ( ) ;
1011
1007
let task_ctx = session_ctx. task_ctx ( ) ;
You can’t perform that action at this time.
0 commit comments