runs the specified plan to completion, draining all input and panic'ing on error
(&self)
| 298 | /// runs the specified plan to completion, draining all input and |
| 299 | /// panic'ing on error |
| 300 | fn run(&self) { |
| 301 | let plan = Arc::clone(&self.plan); |
| 302 | let task_ctx = Arc::clone(&self.task_ctx); |
| 303 | |
| 304 | assert_eq!(plan.output_partitioning().partition_count(), 1); |
| 305 | |
| 306 | self.runtime.block_on(async move { |
| 307 | let mut stream = plan.execute(0, task_ctx).unwrap(); |
| 308 | while let Some(b) = stream.next().await { |
| 309 | b.expect("unexpected execution error"); |
| 310 | } |
| 311 | }) |
| 312 | } |
| 313 | } |
| 314 | |
| 315 | /// Make sort exprs for each column in `schema` |
no test coverage detected