Fix test code

Author: adriangb

datafusion/core/tests/physical_optimizer/filter_pushdown/mod.rs

@@ -595,7 +595,7 @@ fn test_no_pushdown_through_aggregates() {
         Ok:
           - FilterExec: b@1 = bar
           -   CoalesceBatchesExec: target_batch_size=100
-          -     AggregateExec: mode=Final, gby=[a@0 as a, b@1 as b], aggr=[cnt]
+          -     AggregateExec: mode=Final, gby=[a@0 as a, b@1 as b], aggr=[cnt], ordering_mode=PartiallySorted([0])
           -       CoalesceBatchesExec: target_batch_size=10
           -         DataSourceExec: file_groups={1 group: [[test.parquet]]}, projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 = foo
     "

datafusion/core/tests/physical_optimizer/filter_pushdown/util.rs

@@ -142,6 +142,10 @@ impl FileSource for TestSource {
         })
     }
 
+    fn filter(&self) -> Option<Arc<dyn PhysicalExpr>> {
+        self.predicate.clone()
+    }
+
     fn as_any(&self) -> &dyn Any {
         todo!("should not be called")
     }

datafusion/datasource/src/source.rs

@@ -359,6 +359,7 @@ impl ExecutionPlan for DataSourceExec {
         child_pushdown_result: ChildPushdownResult,
         config: &ConfigOptions,
     ) -> Result<FilterPushdownPropagation<Arc<dyn ExecutionPlan>>> {
+        println!("pushing down {:?}", child_pushdown_result);
         // Push any remaining filters into our data source
         let parent_filters = child_pushdown_result
             .parent_filters