Skip to content

Commit 13f0a22

Browse files
committed
add test that really execute parallel query
1 parent 6cfb407 commit 13f0a22

File tree

2 files changed

+20
-0
lines changed

2 files changed

+20
-0
lines changed

test/expected/parallel.out

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -62,3 +62,21 @@ EXPLAIN (COSTS OFF) SELECT * FROM kafka_test_part WHERE ((part = 1 or part = 2)
6262
scanning: PARTITION = 5 AND OFFSET = 12
6363
(10 rows)
6464

65+
SELECT COUNT(*) FROM kafka_test_part ;
66+
count
67+
--------
68+
100000
69+
(1 row)
70+
71+
EXPLAIN (COSTS OFF) SELECT COUNT(*) FROM kafka_test_part ;
72+
QUERY PLAN
73+
--------------------------------------------------------------
74+
Finalize Aggregate
75+
-> Gather
76+
Workers Planned: 3
77+
-> Partial Aggregate
78+
-> Parallel Foreign Scan on kafka_test_part
79+
Kafka topic: contrib_regress4
80+
scanning: PARTITION >= 0 AND OFFSET >= 0
81+
(7 rows)
82+

test/sql/parallel.sql

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -22,3 +22,5 @@ EXPLAIN (COSTS OFF) SELECT * FROM kafka_test_part WHERE offs = 1 AND part = 0;
2222
EXPLAIN (COSTS OFF) SELECT * FROM kafka_test_part WHERE ((part = 1 or part = 2) and offs = 3) OR (part = 4 and offs=7);
2323
EXPLAIN (COSTS OFF) SELECT * FROM kafka_test_part WHERE ((part = 1 or part = 2) and offs = 3) OR ((part = 4 and offs=7 ) or ( part = 5 and (offs = 10 or offs=12)) );
2424

25+
SELECT COUNT(*) FROM kafka_test_part ;
26+
EXPLAIN (COSTS OFF) SELECT COUNT(*) FROM kafka_test_part ;

0 commit comments

Comments
 (0)