(&self)
| 1113 | } |
| 1114 | |
| 1115 | pub fn projected_schema(&self) -> Result<Arc<Schema>> { |
| 1116 | let schema = self.file_source.table_schema().table_schema(); |
| 1117 | match self.file_source.projection() { |
| 1118 | Some(proj) => Ok(Arc::new(proj.project_schema(schema)?)), |
| 1119 | None => Ok(Arc::clone(schema)), |
| 1120 | } |
| 1121 | } |
| 1122 | |
| 1123 | fn add_filter_equivalence_info( |
| 1124 | filter: &Arc<dyn PhysicalExpr>, |