| create schema orca_parallel; |
| set search_path=orca_parallel, public; |
| set statement_mem = '256MB'; |
| set optimizer=on; |
| |
| create table t1(a int, b int) with(parallel_workers=2) distributed by (a); |
| create table t2(c int, d int ) with(parallel_workers=3) distributed by (c); |
| insert into t1 select i, i+1 from generate_series(1, 1000)i; |
| insert into t2 select i, i+2 from generate_series(1, 20000)i; |
| analyze t1; |
| analyze t2; |
| |
| set parallel_setup_cost=0; |
| set max_parallel_workers_per_gather=4; |
| set enable_parallel = on; |
| |
| explain (verbose, costs off) select * from t1 join t2 on t1.a = t2.c; |
| explain (verbose, costs off) select * from t1 join t2 on t1.a = t2.d; |
| explain (verbose, costs off) select * from t1 join t2 on t1.b = t2.c; |
| explain (verbose, costs off) select * from t1 join t2 on t1.b = t2.d; |
| |
| |
| reset enable_parallel; |
| reset max_parallel_workers_per_gather; |
| reset parallel_setup_cost; |
| reset statement_mem; |
| reset optimizer; |
| |
| -- start_ignore |
| drop schema orca_parallel cascade; |
| -- end_ignore |
