Create a physical ExecutionPlan (by way of logical plan)
(ctx: &SessionContext, rt: &Runtime, sql: &str)
| 48 | |
| 49 | /// Create a physical ExecutionPlan (by way of logical plan) |
| 50 | fn physical_plan(ctx: &SessionContext, rt: &Runtime, sql: &str) { |
| 51 | black_box(rt.block_on(async { |
| 52 | ctx.sql(sql) |
| 53 | .await |
| 54 | .unwrap() |
| 55 | .create_physical_plan() |
| 56 | .await |
| 57 | .unwrap() |
| 58 | })); |
| 59 | } |
| 60 | |
| 61 | /// Create schema with the specified number of columns |
| 62 | fn create_schema(column_prefix: &str, num_columns: usize) -> Schema { |
no test coverage detected
searching dependent graphs…