Get the schema
(&self)
| 549 | impl RecordBatchStream for ProjectionStream { |
| 550 | /// Get the schema |
| 551 | fn schema(&self) -> SchemaRef { |
| 552 | Arc::clone(self.projector.output_schema()) |
| 553 | } |
| 554 | } |
| 555 | |
| 556 | /// Trait for execution plans that can embed a projection, avoiding a separate |