(
&self,
order: &[PhysicalSortExpr],
)
| 497 | } |
| 498 | |
| 499 | fn try_pushdown_sort( |
| 500 | &self, |
| 501 | order: &[PhysicalSortExpr], |
| 502 | ) -> Result<SortOrderPushdownResult<Arc<dyn ExecutionPlan>>> { |
| 503 | // Delegate to the data source and wrap result with DataSourceExec |
| 504 | self.data_source |
| 505 | .try_pushdown_sort(order)? |
| 506 | .try_map(|new_data_source| { |
| 507 | let new_exec = self.clone().with_data_source(new_data_source); |
| 508 | Ok(Arc::new(new_exec) as Arc<dyn ExecutionPlan>) |
| 509 | }) |
| 510 | } |
| 511 | |
| 512 | fn with_preserve_order( |
| 513 | &self, |
nothing calls this directly
no test coverage detected