(&self, handle: &str)
| 154 | } |
| 155 | |
| 156 | fn get_result(&self, handle: &str) -> Result<Vec<RecordBatch>, Status> { |
| 157 | if let Some(result) = self.results.get(handle) { |
| 158 | Ok(result.clone()) |
| 159 | } else { |
| 160 | Err(Status::internal(format!( |
| 161 | "Request handle not found: {handle}" |
| 162 | )))? |
| 163 | } |
| 164 | } |
| 165 | |
| 166 | async fn tables(&self, ctx: Arc<SessionContext>) -> RecordBatch { |
| 167 | let schema = Arc::new(Schema::new(vec![ |
no test coverage detected