(&self, handle: &str)
| 146 | } |
| 147 | |
| 148 | fn get_plan(&self, handle: &str) -> Result<LogicalPlan, Status> { |
| 149 | if let Some(plan) = self.statements.get(handle) { |
| 150 | Ok(plan.clone()) |
| 151 | } else { |
| 152 | Err(Status::internal(format!("Plan handle not found: {handle}")))? |
| 153 | } |
| 154 | } |
| 155 | |
| 156 | fn get_result(&self, handle: &str) -> Result<Vec<RecordBatch>, Status> { |
| 157 | if let Some(result) = self.results.get(handle) { |
no test coverage detected