diff --git a/test/expected/parallel.out b/test/expected/parallel.out index df4235f..cd10f2e 100644 --- a/test/expected/parallel.out +++ b/test/expected/parallel.out @@ -62,3 +62,21 @@ EXPLAIN (COSTS OFF) SELECT * FROM kafka_test_part WHERE ((part = 1 or part = 2) scanning: PARTITION = 5 AND OFFSET = 12 (10 rows) +SELECT COUNT(*) FROM kafka_test_part ; + count +-------- + 100000 +(1 row) + +EXPLAIN (COSTS OFF) SELECT COUNT(*) FROM kafka_test_part ; + QUERY PLAN +-------------------------------------------------------------- + Finalize Aggregate + -> Gather + Workers Planned: 3 + -> Partial Aggregate + -> Parallel Foreign Scan on kafka_test_part + Kafka topic: contrib_regress4 + scanning: PARTITION >= 0 AND OFFSET >= 0 +(7 rows) + diff --git a/test/sql/parallel.sql b/test/sql/parallel.sql index 88e1cdf..3f91005 100644 --- a/test/sql/parallel.sql +++ b/test/sql/parallel.sql @@ -22,3 +22,5 @@ EXPLAIN (COSTS OFF) SELECT * FROM kafka_test_part WHERE offs = 1 AND part = 0; EXPLAIN (COSTS OFF) SELECT * FROM kafka_test_part WHERE ((part = 1 or part = 2) and offs = 3) OR (part = 4 and offs=7); 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)) ); +SELECT COUNT(*) FROM kafka_test_part ; +EXPLAIN (COSTS OFF) SELECT COUNT(*) FROM kafka_test_part ; \ No newline at end of file