(&self, _ctx: Arc<TaskContext>)
| 600 | } |
| 601 | |
| 602 | fn execute(&self, _ctx: Arc<TaskContext>) -> SendableRecordBatchStream { |
| 603 | let mut builder = self.builder(); |
| 604 | let config = self.config.clone(); |
| 605 | Box::pin(RecordBatchStreamAdapter::new( |
| 606 | Arc::clone(&self.schema), |
| 607 | // TODO: Stream this |
| 608 | futures::stream::once(async move { |
| 609 | config.make_tables(&mut builder).await?; |
| 610 | Ok(builder.finish()) |
| 611 | }), |
| 612 | )) |
| 613 | } |
| 614 | } |
| 615 | |
| 616 | /// Builds the `information_schema.TABLE` table row by row |
nothing calls this directly
no test coverage detected