Execute an arbitrary physical plan (used for inline sub-plans in multi-way joins).
(
&mut self,
task: &ExecutionTask,
plan: &PhysicalPlan,
)
| 33 | |
| 34 | /// Execute an arbitrary physical plan (used for inline sub-plans in multi-way joins). |
| 35 | pub(in crate::data::executor) fn execute_plan( |
| 36 | &mut self, |
| 37 | task: &ExecutionTask, |
| 38 | plan: &PhysicalPlan, |
| 39 | ) -> Response { |
| 40 | let tid = task.request.tenant_id.as_u64(); |
| 41 | // Record the tenant → database association so maintenance budget |
| 42 | // tracking can resolve per-database caps when iterating collections. |
| 43 | self.record_tenant_database(task.request.tenant_id, task.request.database_id); |
| 44 | let mut v = visitor::DataPlaneVisitor { |
| 45 | core_loop: self, |
| 46 | task, |
| 47 | tid, |
| 48 | }; |
| 49 | match nodedb_physical::dispatch(&mut v, plan) { |
| 50 | Ok(response) => response, |
| 51 | Err(never) => match never {}, |
| 52 | } |
| 53 | } |
| 54 | } |
no test coverage detected