(data_source: &Arc<dyn DataSource>)
| 580 | } |
| 581 | |
| 582 | fn compute_properties(data_source: &Arc<dyn DataSource>) -> PlanProperties { |
| 583 | PlanProperties::new( |
| 584 | data_source.eq_properties(), |
| 585 | data_source.output_partitioning(), |
| 586 | EmissionType::Incremental, |
| 587 | Boundedness::Bounded, |
| 588 | ) |
| 589 | .with_scheduling_type(data_source.scheduling_type()) |
| 590 | } |
| 591 | |
| 592 | /// Downcast the `DataSourceExec`'s `data_source` to a specific file source |
| 593 | /// |
nothing calls this directly
no test coverage detected