(&self)
| 68 | } |
| 69 | |
| 70 | fn projected_file_schema(&self) -> SchemaRef { |
| 71 | let file_schema = self.table_schema.file_schema(); |
| 72 | if self.projection.file_indices.is_empty() { |
| 73 | return Arc::clone(file_schema); |
| 74 | } |
| 75 | |
| 76 | Arc::new(Schema::new( |
| 77 | self.projection |
| 78 | .file_indices |
| 79 | .iter() |
| 80 | .map(|idx| file_schema.field(*idx).clone()) |
| 81 | .collect::<Vec<_>>(), |
| 82 | )) |
| 83 | } |
| 84 | |
| 85 | fn writer_projection_for_schema( |
| 86 | &self, |