postgres/timescaledb
1
0
Fork 0
mirror of https://github.com/timescale/timescaledb.git synced 2025-05-15 01:53:41 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fixed transparent decompress chunk test which seem to be flaky.

Browse Source
This commit is contained in:
Bharathy 2023-04-24 19:40:23 +05:30
parent 2f194e6109
commit 44dc042bb3
6 changed files with 355 additions and 424 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
.github/gh_matrix_builder.py vendored
View File

@ -141,7 +141,7 @@ def macos_config(overrides):
# partialize_finalize is ignored due to #4937
pg15_installcheck_args = "IGNORES='partialize_finalize'"
pg14_installcheck_args = "IGNORES='partialize_finalize transparent_decompress_chunk-14'"
pg14_installcheck_args = "IGNORES='partialize_finalize'"
pg13_installcheck_args = "IGNORES='partialize_finalize'"

181
tsl/test/shared/expected/transparent_decompress_chunk-12.out
View File

@ -4,6 +4,7 @@
\set PREFIX 'EXPLAIN (analyze, costs off, timing off, summary off)'
\set PREFIX_VERBOSE 'EXPLAIN (analyze, costs off, timing off, summary off, verbose)'
\set PREFIX_NO_ANALYZE 'EXPLAIN (verbose, costs off)'
\set PREFIX_NO_VERBOSE 'EXPLAIN (costs off)'
SELECT show_chunks('metrics_compressed') AS "TEST_TABLE" ORDER BY 1::text LIMIT 1 \gset
-- this should use DecompressChunk node
:PREFIX_VERBOSE
@ -657,7 +658,7 @@ QUERY PLAN
DROP VIEW compressed_view;
SET parallel_leader_participation TO off;
-- test INNER JOIN
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM :TEST_TABLE m1
INNER JOIN :TEST_TABLE m2 ON m1.time = m2.time
@ -666,22 +667,20 @@ FROM :TEST_TABLE m1
m1.device_id
LIMIT 10;
QUERY PLAN
Limit (actual rows=10 loops=1)
-> Merge Join (actual rows=10 loops=1)
Limit
-> Merge Join
Merge Cond: ((m1."time" = m2."time") AND (m1.device_id = m2.device_id))
-> Sort (actual rows=10 loops=1)
-> Sort
Sort Key: m1."time", m1.device_id
Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1 (actual rows=17990 loops=1)
-> Seq Scan on compress_hyper_X_X_chunk (actual rows=20 loops=1)
-> Sort (actual rows=10 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1
-> Seq Scan on compress_hyper_X_X_chunk
-> Sort
Sort Key: m2."time", m2.device_id
Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2 (actual rows=17990 loops=1)
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1 (actual rows=20 loops=1)
(13 rows)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1
(11 rows)
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM :TEST_TABLE m1
INNER JOIN :TEST_TABLE m2 ON m1.time = m2.time
@ -692,28 +691,25 @@ FROM :TEST_TABLE m1
m1.device_id
LIMIT 10;
QUERY PLAN
Limit (actual rows=10 loops=1)
-> Nested Loop (actual rows=10 loops=1)
Limit
-> Nested Loop
Join Filter: (m1."time" = m3."time")
Rows Removed by Join Filter: 35969
-> Merge Join (actual rows=10 loops=1)
-> Merge Join
Merge Cond: ((m1."time" = m2."time") AND (m1.device_id = m2.device_id))
-> Sort (actual rows=10 loops=1)
-> Sort
Sort Key: m1."time", m1.device_id
Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1 (actual rows=17990 loops=1)
-> Seq Scan on compress_hyper_X_X_chunk (actual rows=20 loops=1)
-> Sort (actual rows=10 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1
-> Seq Scan on compress_hyper_X_X_chunk
-> Sort
Sort Key: m2."time", m2.device_id
Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2 (actual rows=17990 loops=1)
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1 (actual rows=20 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m3 (actual rows=3598 loops=10)
-> Index Scan using compress_hyper_X_X_chunk__compressed_hypertable_4_device_id__t on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_2 (actual rows=4 loops=10)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m3
-> Index Scan using compress_hyper_X_X_chunk__compressed_hypertable_4_device_id__t on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_2
Index Cond: (device_id = 3)
(19 rows)
(16 rows)
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM :TEST_TABLE m1
INNER JOIN :TEST_TABLE m2 ON m1.time = m2.time
@ -725,19 +721,19 @@ FROM :TEST_TABLE m1
m2.device_id
LIMIT 100;
QUERY PLAN
Limit (actual rows=100 loops=1)
-> Merge Join (actual rows=100 loops=1)
Limit
-> Merge Join
Merge Cond: (m1."time" = m2."time")
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1 (actual rows=100 loops=1)
-> Index Scan Backward using compress_hyper_X_X_chunk__compressed_hypertable_4_device_id__t on compress_hyper_X_X_chunk (actual rows=1 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1
-> Index Scan Backward using compress_hyper_X_X_chunk__compressed_hypertable_4_device_id__t on compress_hyper_X_X_chunk
Index Cond: (device_id = 1)
-> Materialize (actual rows=100 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2 (actual rows=100 loops=1)
-> Index Scan Backward using compress_hyper_X_X_chunk__compressed_hypertable_4_device_id__t on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1 (actual rows=1 loops=1)
-> Materialize
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2
-> Index Scan Backward using compress_hyper_X_X_chunk__compressed_hypertable_4_device_id__t on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1
Index Cond: (device_id = 2)
(10 rows)
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM metrics m1
INNER JOIN metrics_space m2 ON m1.time = m2.time
@ -749,30 +745,30 @@ FROM metrics m1
m2.device_id
LIMIT 100;
QUERY PLAN
Limit (actual rows=100 loops=1)
-> Merge Join (actual rows=100 loops=1)
Limit
-> Merge Join
Merge Cond: (m1."time" = m2."time")
-> Custom Scan (ChunkAppend) on metrics m1 (actual rows=100 loops=1)
-> Custom Scan (ChunkAppend) on metrics m1
Order: m1."time"
-> Index Scan Backward using _hyper_X_X_chunk_metrics_device_id_time_idx on _hyper_X_X_chunk m1_1 (actual rows=100 loops=1)
-> Index Scan Backward using _hyper_X_X_chunk_metrics_device_id_time_idx on _hyper_X_X_chunk m1_1
Index Cond: (device_id = 1)
-> Index Scan Backward using _hyper_X_X_chunk_metrics_device_id_time_idx on _hyper_X_X_chunk m1_2 (never executed)
-> Index Scan Backward using _hyper_X_X_chunk_metrics_device_id_time_idx on _hyper_X_X_chunk m1_2
Index Cond: (device_id = 1)
-> Index Scan Backward using _hyper_X_X_chunk_metrics_device_id_time_idx on _hyper_X_X_chunk m1_3 (never executed)
-> Index Scan Backward using _hyper_X_X_chunk_metrics_device_id_time_idx on _hyper_X_X_chunk m1_3
Index Cond: (device_id = 1)
-> Materialize (actual rows=100 loops=1)
-> Custom Scan (ChunkAppend) on metrics_space m2 (actual rows=100 loops=1)
-> Materialize
-> Custom Scan (ChunkAppend) on metrics_space m2
Order: m2."time"
-> Index Scan using _hyper_X_X_chunk_metrics_space_device_id_time_idx on _hyper_X_X_chunk m2_1 (actual rows=100 loops=1)
-> Index Scan using _hyper_X_X_chunk_metrics_space_device_id_time_idx on _hyper_X_X_chunk m2_1
Index Cond: (device_id = 2)
-> Index Scan using _hyper_X_X_chunk_metrics_space_device_id_time_idx on _hyper_X_X_chunk m2_2 (never executed)
-> Index Scan using _hyper_X_X_chunk_metrics_space_device_id_time_idx on _hyper_X_X_chunk m2_2
Index Cond: (device_id = 2)
-> Index Scan using _hyper_X_X_chunk_metrics_space_device_id_time_idx on _hyper_X_X_chunk m2_3 (never executed)
-> Index Scan using _hyper_X_X_chunk_metrics_space_device_id_time_idx on _hyper_X_X_chunk m2_3
Index Cond: (device_id = 2)
(20 rows)
-- test OUTER JOIN
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM :TEST_TABLE m1
LEFT OUTER JOIN :TEST_TABLE m2 ON m1.time = m2.time
@ -781,22 +777,20 @@ ORDER BY m1.time,
m1.device_id
LIMIT 10;
QUERY PLAN
Limit (actual rows=10 loops=1)
-> Merge Left Join (actual rows=10 loops=1)
Limit
-> Merge Left Join
Merge Cond: ((m1."time" = m2."time") AND (m1.device_id = m2.device_id))
-> Sort (actual rows=10 loops=1)
-> Sort
Sort Key: m1."time", m1.device_id
Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1 (actual rows=17990 loops=1)
-> Seq Scan on compress_hyper_X_X_chunk (actual rows=20 loops=1)
-> Sort (actual rows=10 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1
-> Seq Scan on compress_hyper_X_X_chunk
-> Sort
Sort Key: m2."time", m2.device_id
Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2 (actual rows=17990 loops=1)
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1 (actual rows=20 loops=1)
(13 rows)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1
(11 rows)
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM :TEST_TABLE m1
LEFT OUTER JOIN :TEST_TABLE m2 ON m1.time = m2.time
@ -808,25 +802,22 @@ ORDER BY m1.time,
m2.device_id
LIMIT 100;
QUERY PLAN
Limit (actual rows=100 loops=1)
-> Sort (actual rows=100 loops=1)
Limit
-> Sort
Sort Key: m1."time", m1.device_id, m2."time", m2.device_id
Sort Method: top-N heapsort
-> Hash Left Join (actual rows=17990 loops=1)
-> Hash Left Join
Hash Cond: (m1."time" = m2."time")
Join Filter: (m1.device_id = 1)
Rows Removed by Join Filter: 14392
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1 (actual rows=17990 loops=1)
-> Seq Scan on compress_hyper_X_X_chunk (actual rows=20 loops=1)
-> Hash (actual rows=3598 loops=1)
Buckets: 4096 (originally 1024) Batches: 1 (originally 1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2 (actual rows=3598 loops=1)
-> Index Scan using compress_hyper_X_X_chunk__compressed_hypertable_4_device_id__t on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1 (actual rows=4 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1
-> Seq Scan on compress_hyper_X_X_chunk
-> Hash
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2
-> Index Scan using compress_hyper_X_X_chunk__compressed_hypertable_4_device_id__t on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1
Index Cond: (device_id = 2)
(15 rows)
(12 rows)
-- test implicit self-join
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM :TEST_TABLE m1,
:TEST_TABLE m2
@ -837,22 +828,20 @@ ORDER BY m1.time,
m2.device_id
LIMIT 20;
QUERY PLAN
Limit (actual rows=20 loops=1)
-> Sort (actual rows=20 loops=1)
Limit
-> Sort
Sort Key: m1."time", m1.device_id, m2.device_id
Sort Method: top-N heapsort
-> Hash Join (actual rows=89950 loops=1)
-> Hash Join
Hash Cond: (m1."time" = m2."time")
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1 (actual rows=17990 loops=1)
-> Seq Scan on compress_hyper_X_X_chunk (actual rows=20 loops=1)
-> Hash (actual rows=17990 loops=1)
Buckets: 32768 Batches: 1
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2 (actual rows=17990 loops=1)
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1 (actual rows=20 loops=1)
(12 rows)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1
-> Seq Scan on compress_hyper_X_X_chunk
-> Hash
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1
(10 rows)
-- test self-join with sub-query
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM (
SELECT *
@ -865,19 +854,17 @@ ORDER BY m1.time,
m2.device_id
LIMIT 10;
QUERY PLAN
Limit (actual rows=10 loops=1)
-> Sort (actual rows=10 loops=1)
Limit
-> Sort
Sort Key: m1."time", m1.device_id, m2.device_id
Sort Method: top-N heapsort
-> Hash Join (actual rows=89950 loops=1)
-> Hash Join
Hash Cond: (m1."time" = m2."time")
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1 (actual rows=17990 loops=1)
-> Seq Scan on compress_hyper_X_X_chunk (actual rows=20 loops=1)
-> Hash (actual rows=17990 loops=1)
Buckets: 32768 Batches: 1
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2 (actual rows=17990 loops=1)
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1 (actual rows=20 loops=1)
(12 rows)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1
-> Seq Scan on compress_hyper_X_X_chunk
-> Hash
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1
(10 rows)
RESET parallel_leader_participation;
:PREFIX

193
tsl/test/shared/expected/transparent_decompress_chunk-13.out
View File

@ -4,6 +4,7 @@
\set PREFIX 'EXPLAIN (analyze, costs off, timing off, summary off)'
\set PREFIX_VERBOSE 'EXPLAIN (analyze, costs off, timing off, summary off, verbose)'
\set PREFIX_NO_ANALYZE 'EXPLAIN (verbose, costs off)'
\set PREFIX_NO_VERBOSE 'EXPLAIN (costs off)'
SELECT show_chunks('metrics_compressed') AS "TEST_TABLE" ORDER BY 1::text LIMIT 1 \gset
-- this should use DecompressChunk node
:PREFIX_VERBOSE
@ -659,7 +660,7 @@ QUERY PLAN
DROP VIEW compressed_view;
SET parallel_leader_participation TO off;
-- test INNER JOIN
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM :TEST_TABLE m1
INNER JOIN :TEST_TABLE m2 ON m1.time = m2.time
@ -668,23 +669,20 @@ FROM :TEST_TABLE m1
m1.device_id
LIMIT 10;
QUERY PLAN
Limit (actual rows=10 loops=1)
-> Nested Loop (actual rows=10 loops=1)
Limit
-> Nested Loop
Join Filter: ((m1."time" = m2."time") AND (m1.device_id = m2.device_id))
Rows Removed by Join Filter: 179889
-> Gather Merge (actual rows=10 loops=1)
-> Gather Merge
Workers Planned: 1
Workers Launched: 1
-> Sort (actual rows=1025 loops=1)
-> Sort
Sort Key: m1."time", m1.device_id
Worker 0: Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1 (actual rows=17990 loops=1)
-> Parallel Seq Scan on compress_hyper_X_X_chunk (actual rows=20 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2 (actual rows=17990 loops=10)
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1 (actual rows=20 loops=10)
(14 rows)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1
-> Parallel Seq Scan on compress_hyper_X_X_chunk
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1
(11 rows)
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM :TEST_TABLE m1
INNER JOIN :TEST_TABLE m2 ON m1.time = m2.time
@ -695,29 +693,25 @@ FROM :TEST_TABLE m1
m1.device_id
LIMIT 10;
QUERY PLAN
Limit (actual rows=10 loops=1)
-> Nested Loop (actual rows=10 loops=1)
Limit
-> Nested Loop
Join Filter: (m1."time" = m3."time")
Rows Removed by Join Filter: 35969
-> Nested Loop (actual rows=10 loops=1)
-> Nested Loop
Join Filter: ((m1."time" = m2."time") AND (m1.device_id = m2.device_id))
Rows Removed by Join Filter: 179889
-> Gather Merge (actual rows=10 loops=1)
-> Gather Merge
Workers Planned: 1
Workers Launched: 1
-> Sort (actual rows=1025 loops=1)
-> Sort
Sort Key: m1."time", m1.device_id
Worker 0: Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1 (actual rows=17990 loops=1)
-> Parallel Seq Scan on compress_hyper_X_X_chunk (actual rows=20 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2 (actual rows=17990 loops=10)
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1 (actual rows=20 loops=10)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m3 (actual rows=3598 loops=10)
-> Index Scan using compress_hyper_X_X_chunk__compressed_hypertable_4_device_id__t on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_2 (actual rows=4 loops=10)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1
-> Parallel Seq Scan on compress_hyper_X_X_chunk
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m3
-> Index Scan using compress_hyper_X_X_chunk__compressed_hypertable_4_device_id__t on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_2
Index Cond: (device_id = 3)
(20 rows)
(16 rows)
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM :TEST_TABLE m1
INNER JOIN :TEST_TABLE m2 ON m1.time = m2.time
@ -729,19 +723,19 @@ FROM :TEST_TABLE m1
m2.device_id
LIMIT 100;
QUERY PLAN
Limit (actual rows=100 loops=1)
-> Merge Join (actual rows=100 loops=1)
Limit
-> Merge Join
Merge Cond: (m1."time" = m2."time")
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1 (actual rows=100 loops=1)
-> Index Scan Backward using compress_hyper_X_X_chunk__compressed_hypertable_4_device_id__t on compress_hyper_X_X_chunk (actual rows=1 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1
-> Index Scan Backward using compress_hyper_X_X_chunk__compressed_hypertable_4_device_id__t on compress_hyper_X_X_chunk
Index Cond: (device_id = 1)
-> Materialize (actual rows=100 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2 (actual rows=100 loops=1)
-> Index Scan Backward using compress_hyper_X_X_chunk__compressed_hypertable_4_device_id__t on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1 (actual rows=1 loops=1)
-> Materialize
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2
-> Index Scan Backward using compress_hyper_X_X_chunk__compressed_hypertable_4_device_id__t on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1
Index Cond: (device_id = 2)
(10 rows)
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM metrics m1
INNER JOIN metrics_space m2 ON m1.time = m2.time
@ -753,30 +747,30 @@ FROM metrics m1
m2.device_id
LIMIT 100;
QUERY PLAN
Limit (actual rows=100 loops=1)
-> Merge Join (actual rows=100 loops=1)
Limit
-> Merge Join
Merge Cond: (m1."time" = m2."time")
-> Custom Scan (ChunkAppend) on metrics m1 (actual rows=100 loops=1)
-> Custom Scan (ChunkAppend) on metrics m1
Order: m1."time"
-> Index Scan Backward using _hyper_X_X_chunk_metrics_device_id_time_idx on _hyper_X_X_chunk m1_1 (actual rows=100 loops=1)
-> Index Scan Backward using _hyper_X_X_chunk_metrics_device_id_time_idx on _hyper_X_X_chunk m1_1
Index Cond: (device_id = 1)
-> Index Scan Backward using _hyper_X_X_chunk_metrics_device_id_time_idx on _hyper_X_X_chunk m1_2 (never executed)
-> Index Scan Backward using _hyper_X_X_chunk_metrics_device_id_time_idx on _hyper_X_X_chunk m1_2
Index Cond: (device_id = 1)
-> Index Scan Backward using _hyper_X_X_chunk_metrics_device_id_time_idx on _hyper_X_X_chunk m1_3 (never executed)
-> Index Scan Backward using _hyper_X_X_chunk_metrics_device_id_time_idx on _hyper_X_X_chunk m1_3
Index Cond: (device_id = 1)
-> Materialize (actual rows=100 loops=1)
-> Custom Scan (ChunkAppend) on metrics_space m2 (actual rows=100 loops=1)
-> Materialize
-> Custom Scan (ChunkAppend) on metrics_space m2
Order: m2."time"
-> Index Scan using _hyper_X_X_chunk_metrics_space_device_id_time_idx on _hyper_X_X_chunk m2_1 (actual rows=100 loops=1)
-> Index Scan using _hyper_X_X_chunk_metrics_space_device_id_time_idx on _hyper_X_X_chunk m2_1
Index Cond: (device_id = 2)
-> Index Scan using _hyper_X_X_chunk_metrics_space_device_id_time_idx on _hyper_X_X_chunk m2_2 (never executed)
-> Index Scan using _hyper_X_X_chunk_metrics_space_device_id_time_idx on _hyper_X_X_chunk m2_2
Index Cond: (device_id = 2)
-> Index Scan using _hyper_X_X_chunk_metrics_space_device_id_time_idx on _hyper_X_X_chunk m2_3 (never executed)
-> Index Scan using _hyper_X_X_chunk_metrics_space_device_id_time_idx on _hyper_X_X_chunk m2_3
Index Cond: (device_id = 2)
(20 rows)
-- test OUTER JOIN
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM :TEST_TABLE m1
LEFT OUTER JOIN :TEST_TABLE m2 ON m1.time = m2.time
@ -785,23 +779,20 @@ ORDER BY m1.time,
m1.device_id
LIMIT 10;
QUERY PLAN
Limit (actual rows=10 loops=1)
-> Nested Loop Left Join (actual rows=10 loops=1)
Limit
-> Nested Loop Left Join
Join Filter: ((m1."time" = m2."time") AND (m1.device_id = m2.device_id))
Rows Removed by Join Filter: 179889
-> Gather Merge (actual rows=10 loops=1)
-> Gather Merge
Workers Planned: 1
Workers Launched: 1
-> Sort (actual rows=1025 loops=1)
-> Sort
Sort Key: m1."time", m1.device_id
Worker 0: Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1 (actual rows=17990 loops=1)
-> Parallel Seq Scan on compress_hyper_X_X_chunk (actual rows=20 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2 (actual rows=17990 loops=10)
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1 (actual rows=20 loops=10)
(14 rows)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1
-> Parallel Seq Scan on compress_hyper_X_X_chunk
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1
(11 rows)
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM :TEST_TABLE m1
LEFT OUTER JOIN :TEST_TABLE m2 ON m1.time = m2.time
@ -813,30 +804,26 @@ ORDER BY m1.time,
m2.device_id
LIMIT 100;
QUERY PLAN
Limit (actual rows=100 loops=1)
-> Incremental Sort (actual rows=100 loops=1)
Limit
-> Incremental Sort
Sort Key: m1."time", m1.device_id, m2."time", m2.device_id
Presorted Key: m1."time"
Full-sort Groups: 3 Sort Method: quicksort
-> Merge Left Join (actual rows=101 loops=1)
-> Merge Left Join
Merge Cond: (m1."time" = m2."time")
Join Filter: (m1.device_id = 1)
Rows Removed by Join Filter: 81
-> Sort (actual rows=101 loops=1)
-> Sort
Sort Key: m1."time"
Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1 (actual rows=17990 loops=1)
-> Seq Scan on compress_hyper_X_X_chunk (actual rows=20 loops=1)
-> Sort (actual rows=102 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1
-> Seq Scan on compress_hyper_X_X_chunk
-> Sort
Sort Key: m2."time"
Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2 (actual rows=3598 loops=1)
-> Index Scan using compress_hyper_X_X_chunk__compressed_hypertable_4_device_id__t on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1 (actual rows=4 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2
-> Index Scan using compress_hyper_X_X_chunk__compressed_hypertable_4_device_id__t on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1
Index Cond: (device_id = 2)
(20 rows)
(16 rows)
-- test implicit self-join
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM :TEST_TABLE m1,
:TEST_TABLE m2
@ -847,27 +834,24 @@ ORDER BY m1.time,
m2.device_id
LIMIT 20;
QUERY PLAN
Limit (actual rows=20 loops=1)
-> Incremental Sort (actual rows=20 loops=1)
Limit
-> Incremental Sort
Sort Key: m1."time", m1.device_id, m2.device_id
Presorted Key: m1."time"
Full-sort Groups: 1 Sort Method: quicksort
-> Merge Join (actual rows=26 loops=1)
-> Merge Join
Merge Cond: (m1."time" = m2."time")
-> Sort (actual rows=6 loops=1)
-> Sort
Sort Key: m1."time"
Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1 (actual rows=17990 loops=1)
-> Seq Scan on compress_hyper_X_X_chunk (actual rows=20 loops=1)
-> Sort (actual rows=26 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1
-> Seq Scan on compress_hyper_X_X_chunk
-> Sort
Sort Key: m2."time"
Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2 (actual rows=17990 loops=1)
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1 (actual rows=20 loops=1)
(17 rows)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1
(14 rows)
-- test self-join with sub-query
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM (
SELECT *
@ -880,24 +864,21 @@ ORDER BY m1.time,
m2.device_id
LIMIT 10;
QUERY PLAN
Limit (actual rows=10 loops=1)
-> Incremental Sort (actual rows=10 loops=1)
Limit
-> Incremental Sort
Sort Key: m1."time", m1.device_id, m2.device_id
Presorted Key: m1."time"
Full-sort Groups: 1 Sort Method: top-N heapsort
-> Merge Join (actual rows=26 loops=1)
-> Merge Join
Merge Cond: (m1."time" = m2."time")
-> Sort (actual rows=6 loops=1)
-> Sort
Sort Key: m1."time"
Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1 (actual rows=17990 loops=1)
-> Seq Scan on compress_hyper_X_X_chunk (actual rows=20 loops=1)
-> Sort (actual rows=26 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1
-> Seq Scan on compress_hyper_X_X_chunk
-> Sort
Sort Key: m2."time"
Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2 (actual rows=17990 loops=1)
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1 (actual rows=20 loops=1)
(17 rows)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1
(14 rows)
RESET parallel_leader_participation;
:PREFIX

193
tsl/test/shared/expected/transparent_decompress_chunk-14.out
View File

@ -4,6 +4,7 @@
\set PREFIX 'EXPLAIN (analyze, costs off, timing off, summary off)'
\set PREFIX_VERBOSE 'EXPLAIN (analyze, costs off, timing off, summary off, verbose)'
\set PREFIX_NO_ANALYZE 'EXPLAIN (verbose, costs off)'
\set PREFIX_NO_VERBOSE 'EXPLAIN (costs off)'
SELECT show_chunks('metrics_compressed') AS "TEST_TABLE" ORDER BY 1::text LIMIT 1 \gset
-- this should use DecompressChunk node
:PREFIX_VERBOSE
@ -659,7 +660,7 @@ QUERY PLAN
DROP VIEW compressed_view;
SET parallel_leader_participation TO off;
-- test INNER JOIN
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM :TEST_TABLE m1
INNER JOIN :TEST_TABLE m2 ON m1.time = m2.time
@ -668,23 +669,20 @@ FROM :TEST_TABLE m1
m1.device_id
LIMIT 10;
QUERY PLAN
Limit (actual rows=10 loops=1)
-> Nested Loop (actual rows=10 loops=1)
Limit
-> Nested Loop
Join Filter: ((m1."time" = m2."time") AND (m1.device_id = m2.device_id))
Rows Removed by Join Filter: 179889
-> Gather Merge (actual rows=10 loops=1)
-> Gather Merge
Workers Planned: 1
Workers Launched: 1
-> Sort (actual rows=1171 loops=1)
-> Sort
Sort Key: m1."time", m1.device_id
Worker 0: Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1 (actual rows=17990 loops=1)
-> Parallel Seq Scan on compress_hyper_X_X_chunk (actual rows=20 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2 (actual rows=17990 loops=10)
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1 (actual rows=20 loops=10)
(14 rows)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1
-> Parallel Seq Scan on compress_hyper_X_X_chunk
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1
(11 rows)
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM :TEST_TABLE m1
INNER JOIN :TEST_TABLE m2 ON m1.time = m2.time
@ -695,29 +693,25 @@ FROM :TEST_TABLE m1
m1.device_id
LIMIT 10;
QUERY PLAN
Limit (actual rows=10 loops=1)
-> Nested Loop (actual rows=10 loops=1)
Limit
-> Nested Loop
Join Filter: (m1."time" = m3."time")
Rows Removed by Join Filter: 35969
-> Nested Loop (actual rows=10 loops=1)
-> Nested Loop
Join Filter: ((m1."time" = m2."time") AND (m1.device_id = m2.device_id))
Rows Removed by Join Filter: 179889
-> Gather Merge (actual rows=10 loops=1)
-> Gather Merge
Workers Planned: 1
Workers Launched: 1
-> Sort (actual rows=1171 loops=1)
-> Sort
Sort Key: m1."time", m1.device_id
Worker 0: Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1 (actual rows=17990 loops=1)
-> Parallel Seq Scan on compress_hyper_X_X_chunk (actual rows=20 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2 (actual rows=17990 loops=10)
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1 (actual rows=20 loops=10)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m3 (actual rows=3598 loops=10)
-> Index Scan using compress_hyper_X_X_chunk__compressed_hypertable_4_device_id__t on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_2 (actual rows=4 loops=10)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1
-> Parallel Seq Scan on compress_hyper_X_X_chunk
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m3
-> Index Scan using compress_hyper_X_X_chunk__compressed_hypertable_4_device_id__t on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_2
Index Cond: (device_id = 3)
(20 rows)
(16 rows)
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM :TEST_TABLE m1
INNER JOIN :TEST_TABLE m2 ON m1.time = m2.time
@ -729,19 +723,19 @@ FROM :TEST_TABLE m1
m2.device_id
LIMIT 100;
QUERY PLAN
Limit (actual rows=100 loops=1)
-> Merge Join (actual rows=100 loops=1)
Limit
-> Merge Join
Merge Cond: (m1."time" = m2."time")
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1 (actual rows=100 loops=1)
-> Index Scan Backward using compress_hyper_X_X_chunk__compressed_hypertable_4_device_id__t on compress_hyper_X_X_chunk (actual rows=1 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1
-> Index Scan Backward using compress_hyper_X_X_chunk__compressed_hypertable_4_device_id__t on compress_hyper_X_X_chunk
Index Cond: (device_id = 1)
-> Materialize (actual rows=100 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2 (actual rows=100 loops=1)
-> Index Scan Backward using compress_hyper_X_X_chunk__compressed_hypertable_4_device_id__t on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1 (actual rows=1 loops=1)
-> Materialize
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2
-> Index Scan Backward using compress_hyper_X_X_chunk__compressed_hypertable_4_device_id__t on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1
Index Cond: (device_id = 2)
(10 rows)
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM metrics m1
INNER JOIN metrics_space m2 ON m1.time = m2.time
@ -753,30 +747,30 @@ FROM metrics m1
m2.device_id
LIMIT 100;
QUERY PLAN
Limit (actual rows=100 loops=1)
-> Merge Join (actual rows=100 loops=1)
Limit
-> Merge Join
Merge Cond: (m1."time" = m2."time")
-> Custom Scan (ChunkAppend) on metrics m1 (actual rows=100 loops=1)
-> Custom Scan (ChunkAppend) on metrics m1
Order: m1."time"
-> Index Scan Backward using _hyper_X_X_chunk_metrics_device_id_time_idx on _hyper_X_X_chunk m1_1 (actual rows=100 loops=1)
-> Index Scan Backward using _hyper_X_X_chunk_metrics_device_id_time_idx on _hyper_X_X_chunk m1_1
Index Cond: (device_id = 1)
-> Index Scan Backward using _hyper_X_X_chunk_metrics_device_id_time_idx on _hyper_X_X_chunk m1_2 (never executed)
-> Index Scan Backward using _hyper_X_X_chunk_metrics_device_id_time_idx on _hyper_X_X_chunk m1_2
Index Cond: (device_id = 1)
-> Index Scan Backward using _hyper_X_X_chunk_metrics_device_id_time_idx on _hyper_X_X_chunk m1_3 (never executed)
-> Index Scan Backward using _hyper_X_X_chunk_metrics_device_id_time_idx on _hyper_X_X_chunk m1_3
Index Cond: (device_id = 1)
-> Materialize (actual rows=100 loops=1)
-> Custom Scan (ChunkAppend) on metrics_space m2 (actual rows=100 loops=1)
-> Materialize
-> Custom Scan (ChunkAppend) on metrics_space m2
Order: m2."time"
-> Index Scan using _hyper_X_X_chunk_metrics_space_device_id_time_idx on _hyper_X_X_chunk m2_1 (actual rows=100 loops=1)
-> Index Scan using _hyper_X_X_chunk_metrics_space_device_id_time_idx on _hyper_X_X_chunk m2_1
Index Cond: (device_id = 2)
-> Index Scan using _hyper_X_X_chunk_metrics_space_device_id_time_idx on _hyper_X_X_chunk m2_2 (never executed)
-> Index Scan using _hyper_X_X_chunk_metrics_space_device_id_time_idx on _hyper_X_X_chunk m2_2
Index Cond: (device_id = 2)
-> Index Scan using _hyper_X_X_chunk_metrics_space_device_id_time_idx on _hyper_X_X_chunk m2_3 (never executed)
-> Index Scan using _hyper_X_X_chunk_metrics_space_device_id_time_idx on _hyper_X_X_chunk m2_3
Index Cond: (device_id = 2)
(20 rows)
-- test OUTER JOIN
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM :TEST_TABLE m1
LEFT OUTER JOIN :TEST_TABLE m2 ON m1.time = m2.time
@ -785,23 +779,20 @@ ORDER BY m1.time,
m1.device_id
LIMIT 10;
QUERY PLAN
Limit (actual rows=10 loops=1)
-> Nested Loop Left Join (actual rows=10 loops=1)
Limit
-> Nested Loop Left Join
Join Filter: ((m1."time" = m2."time") AND (m1.device_id = m2.device_id))
Rows Removed by Join Filter: 179889
-> Gather Merge (actual rows=10 loops=1)
-> Gather Merge
Workers Planned: 1
Workers Launched: 1
-> Sort (actual rows=1171 loops=1)
-> Sort
Sort Key: m1."time", m1.device_id
Worker 0: Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1 (actual rows=17990 loops=1)
-> Parallel Seq Scan on compress_hyper_X_X_chunk (actual rows=20 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2 (actual rows=17990 loops=10)
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1 (actual rows=20 loops=10)
(14 rows)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1
-> Parallel Seq Scan on compress_hyper_X_X_chunk
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1
(11 rows)
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM :TEST_TABLE m1
LEFT OUTER JOIN :TEST_TABLE m2 ON m1.time = m2.time
@ -813,30 +804,26 @@ ORDER BY m1.time,
m2.device_id
LIMIT 100;
QUERY PLAN
Limit (actual rows=100 loops=1)
-> Incremental Sort (actual rows=100 loops=1)
Limit
-> Incremental Sort
Sort Key: m1."time", m1.device_id, m2."time", m2.device_id
Presorted Key: m1."time"
Full-sort Groups: 3 Sort Method: quicksort
-> Merge Left Join (actual rows=101 loops=1)
-> Merge Left Join
Merge Cond: (m1."time" = m2."time")
Join Filter: (m1.device_id = 1)
Rows Removed by Join Filter: 81
-> Sort (actual rows=101 loops=1)
-> Sort
Sort Key: m1."time"
Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1 (actual rows=17990 loops=1)
-> Seq Scan on compress_hyper_X_X_chunk (actual rows=20 loops=1)
-> Sort (actual rows=102 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1
-> Seq Scan on compress_hyper_X_X_chunk
-> Sort
Sort Key: m2."time"
Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2 (actual rows=3598 loops=1)
-> Index Scan using compress_hyper_X_X_chunk__compressed_hypertable_4_device_id__t on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1 (actual rows=4 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2
-> Index Scan using compress_hyper_X_X_chunk__compressed_hypertable_4_device_id__t on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1
Index Cond: (device_id = 2)
(20 rows)
(16 rows)
-- test implicit self-join
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM :TEST_TABLE m1,
:TEST_TABLE m2
@ -847,27 +834,24 @@ ORDER BY m1.time,
m2.device_id
LIMIT 20;
QUERY PLAN
Limit (actual rows=20 loops=1)
-> Incremental Sort (actual rows=20 loops=1)
Limit
-> Incremental Sort
Sort Key: m1."time", m1.device_id, m2.device_id
Presorted Key: m1."time"
Full-sort Groups: 1 Sort Method: quicksort
-> Merge Join (actual rows=26 loops=1)
-> Merge Join
Merge Cond: (m1."time" = m2."time")
-> Sort (actual rows=6 loops=1)
-> Sort
Sort Key: m1."time"
Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1 (actual rows=17990 loops=1)
-> Seq Scan on compress_hyper_X_X_chunk (actual rows=20 loops=1)
-> Sort (actual rows=26 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1
-> Seq Scan on compress_hyper_X_X_chunk
-> Sort
Sort Key: m2."time"
Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2 (actual rows=17990 loops=1)
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1 (actual rows=20 loops=1)
(17 rows)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1
(14 rows)
-- test self-join with sub-query
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM (
SELECT *
@ -880,24 +864,21 @@ ORDER BY m1.time,
m2.device_id
LIMIT 10;
QUERY PLAN
Limit (actual rows=10 loops=1)
-> Incremental Sort (actual rows=10 loops=1)
Limit
-> Incremental Sort
Sort Key: m1."time", m1.device_id, m2.device_id
Presorted Key: m1."time"
Full-sort Groups: 1 Sort Method: top-N heapsort
-> Merge Join (actual rows=26 loops=1)
-> Merge Join
Merge Cond: (m1."time" = m2."time")
-> Sort (actual rows=6 loops=1)
-> Sort
Sort Key: m1."time"
Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1 (actual rows=17990 loops=1)
-> Seq Scan on compress_hyper_X_X_chunk (actual rows=20 loops=1)
-> Sort (actual rows=26 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1
-> Seq Scan on compress_hyper_X_X_chunk
-> Sort
Sort Key: m2."time"
Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2 (actual rows=17990 loops=1)
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1 (actual rows=20 loops=1)
(17 rows)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1
(14 rows)
RESET parallel_leader_participation;
:PREFIX

193
tsl/test/shared/expected/transparent_decompress_chunk-15.out
View File

@ -4,6 +4,7 @@
\set PREFIX 'EXPLAIN (analyze, costs off, timing off, summary off)'
\set PREFIX_VERBOSE 'EXPLAIN (analyze, costs off, timing off, summary off, verbose)'
\set PREFIX_NO_ANALYZE 'EXPLAIN (verbose, costs off)'
\set PREFIX_NO_VERBOSE 'EXPLAIN (costs off)'
SELECT show_chunks('metrics_compressed') AS "TEST_TABLE" ORDER BY 1::text LIMIT 1 \gset
-- this should use DecompressChunk node
:PREFIX_VERBOSE
@ -661,7 +662,7 @@ QUERY PLAN
DROP VIEW compressed_view;
SET parallel_leader_participation TO off;
-- test INNER JOIN
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM :TEST_TABLE m1
INNER JOIN :TEST_TABLE m2 ON m1.time = m2.time
@ -670,23 +671,20 @@ FROM :TEST_TABLE m1
m1.device_id
LIMIT 10;
QUERY PLAN
Limit (actual rows=10 loops=1)
-> Nested Loop (actual rows=10 loops=1)
Limit
-> Nested Loop
Join Filter: ((m1."time" = m2."time") AND (m1.device_id = m2.device_id))
Rows Removed by Join Filter: 179889
-> Gather Merge (actual rows=10 loops=1)
-> Gather Merge
Workers Planned: 1
Workers Launched: 1
-> Sort (actual rows=1170 loops=1)
-> Sort
Sort Key: m1."time", m1.device_id
Worker 0: Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1 (actual rows=17990 loops=1)
-> Parallel Seq Scan on compress_hyper_X_X_chunk (actual rows=20 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2 (actual rows=17990 loops=10)
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1 (actual rows=20 loops=10)
(14 rows)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1
-> Parallel Seq Scan on compress_hyper_X_X_chunk
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1
(11 rows)
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM :TEST_TABLE m1
INNER JOIN :TEST_TABLE m2 ON m1.time = m2.time
@ -697,29 +695,25 @@ FROM :TEST_TABLE m1
m1.device_id
LIMIT 10;
QUERY PLAN
Limit (actual rows=10 loops=1)
-> Nested Loop (actual rows=10 loops=1)
Limit
-> Nested Loop
Join Filter: (m1."time" = m3."time")
Rows Removed by Join Filter: 35969
-> Nested Loop (actual rows=10 loops=1)
-> Nested Loop
Join Filter: ((m1."time" = m2."time") AND (m1.device_id = m2.device_id))
Rows Removed by Join Filter: 179889
-> Gather Merge (actual rows=10 loops=1)
-> Gather Merge
Workers Planned: 1
Workers Launched: 1
-> Sort (actual rows=1170 loops=1)
-> Sort
Sort Key: m1."time", m1.device_id
Worker 0: Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1 (actual rows=17990 loops=1)
-> Parallel Seq Scan on compress_hyper_X_X_chunk (actual rows=20 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2 (actual rows=17990 loops=10)
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1 (actual rows=20 loops=10)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m3 (actual rows=3598 loops=10)
-> Index Scan using compress_hyper_X_X_chunk__compressed_hypertable_4_device_id__t on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_2 (actual rows=4 loops=10)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1
-> Parallel Seq Scan on compress_hyper_X_X_chunk
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m3
-> Index Scan using compress_hyper_X_X_chunk__compressed_hypertable_4_device_id__t on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_2
Index Cond: (device_id = 3)
(20 rows)
(16 rows)
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM :TEST_TABLE m1
INNER JOIN :TEST_TABLE m2 ON m1.time = m2.time
@ -731,19 +725,19 @@ FROM :TEST_TABLE m1
m2.device_id
LIMIT 100;
QUERY PLAN
Limit (actual rows=100 loops=1)
-> Merge Join (actual rows=100 loops=1)
Limit
-> Merge Join
Merge Cond: (m1."time" = m2."time")
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1 (actual rows=100 loops=1)
-> Index Scan Backward using compress_hyper_X_X_chunk__compressed_hypertable_4_device_id__t on compress_hyper_X_X_chunk (actual rows=1 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1
-> Index Scan Backward using compress_hyper_X_X_chunk__compressed_hypertable_4_device_id__t on compress_hyper_X_X_chunk
Index Cond: (device_id = 1)
-> Materialize (actual rows=100 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2 (actual rows=100 loops=1)
-> Index Scan Backward using compress_hyper_X_X_chunk__compressed_hypertable_4_device_id__t on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1 (actual rows=1 loops=1)
-> Materialize
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2
-> Index Scan Backward using compress_hyper_X_X_chunk__compressed_hypertable_4_device_id__t on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1
Index Cond: (device_id = 2)
(10 rows)
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM metrics m1
INNER JOIN metrics_space m2 ON m1.time = m2.time
@ -755,30 +749,30 @@ FROM metrics m1
m2.device_id
LIMIT 100;
QUERY PLAN
Limit (actual rows=100 loops=1)
-> Merge Join (actual rows=100 loops=1)
Limit
-> Merge Join
Merge Cond: (m1."time" = m2."time")
-> Custom Scan (ChunkAppend) on metrics m1 (actual rows=100 loops=1)
-> Custom Scan (ChunkAppend) on metrics m1
Order: m1."time"
-> Index Scan Backward using _hyper_X_X_chunk_metrics_device_id_time_idx on _hyper_X_X_chunk m1_1 (actual rows=100 loops=1)
-> Index Scan Backward using _hyper_X_X_chunk_metrics_device_id_time_idx on _hyper_X_X_chunk m1_1
Index Cond: (device_id = 1)
-> Index Scan Backward using _hyper_X_X_chunk_metrics_device_id_time_idx on _hyper_X_X_chunk m1_2 (never executed)
-> Index Scan Backward using _hyper_X_X_chunk_metrics_device_id_time_idx on _hyper_X_X_chunk m1_2
Index Cond: (device_id = 1)
-> Index Scan Backward using _hyper_X_X_chunk_metrics_device_id_time_idx on _hyper_X_X_chunk m1_3 (never executed)
-> Index Scan Backward using _hyper_X_X_chunk_metrics_device_id_time_idx on _hyper_X_X_chunk m1_3
Index Cond: (device_id = 1)
-> Materialize (actual rows=100 loops=1)
-> Custom Scan (ChunkAppend) on metrics_space m2 (actual rows=100 loops=1)
-> Materialize
-> Custom Scan (ChunkAppend) on metrics_space m2
Order: m2."time"
-> Index Scan using _hyper_X_X_chunk_metrics_space_device_id_time_idx on _hyper_X_X_chunk m2_1 (actual rows=100 loops=1)
-> Index Scan using _hyper_X_X_chunk_metrics_space_device_id_time_idx on _hyper_X_X_chunk m2_1
Index Cond: (device_id = 2)
-> Index Scan using _hyper_X_X_chunk_metrics_space_device_id_time_idx on _hyper_X_X_chunk m2_2 (never executed)
-> Index Scan using _hyper_X_X_chunk_metrics_space_device_id_time_idx on _hyper_X_X_chunk m2_2
Index Cond: (device_id = 2)
-> Index Scan using _hyper_X_X_chunk_metrics_space_device_id_time_idx on _hyper_X_X_chunk m2_3 (never executed)
-> Index Scan using _hyper_X_X_chunk_metrics_space_device_id_time_idx on _hyper_X_X_chunk m2_3
Index Cond: (device_id = 2)
(20 rows)
-- test OUTER JOIN
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM :TEST_TABLE m1
LEFT OUTER JOIN :TEST_TABLE m2 ON m1.time = m2.time
@ -787,23 +781,20 @@ ORDER BY m1.time,
m1.device_id
LIMIT 10;
QUERY PLAN
Limit (actual rows=10 loops=1)
-> Nested Loop Left Join (actual rows=10 loops=1)
Limit
-> Nested Loop Left Join
Join Filter: ((m1."time" = m2."time") AND (m1.device_id = m2.device_id))
Rows Removed by Join Filter: 179889
-> Gather Merge (actual rows=10 loops=1)
-> Gather Merge
Workers Planned: 1
Workers Launched: 1
-> Sort (actual rows=1170 loops=1)
-> Sort
Sort Key: m1."time", m1.device_id
Worker 0: Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1 (actual rows=17990 loops=1)
-> Parallel Seq Scan on compress_hyper_X_X_chunk (actual rows=20 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2 (actual rows=17990 loops=10)
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1 (actual rows=20 loops=10)
(14 rows)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1
-> Parallel Seq Scan on compress_hyper_X_X_chunk
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1
(11 rows)
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM :TEST_TABLE m1
LEFT OUTER JOIN :TEST_TABLE m2 ON m1.time = m2.time
@ -815,30 +806,26 @@ ORDER BY m1.time,
m2.device_id
LIMIT 100;
QUERY PLAN
Limit (actual rows=100 loops=1)
-> Incremental Sort (actual rows=100 loops=1)
Limit
-> Incremental Sort
Sort Key: m1."time", m1.device_id, m2."time", m2.device_id
Presorted Key: m1."time"
Full-sort Groups: 3 Sort Method: quicksort
-> Merge Left Join (actual rows=101 loops=1)
-> Merge Left Join
Merge Cond: (m1."time" = m2."time")
Join Filter: (m1.device_id = 1)
Rows Removed by Join Filter: 81
-> Sort (actual rows=101 loops=1)
-> Sort
Sort Key: m1."time"
Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1 (actual rows=17990 loops=1)
-> Seq Scan on compress_hyper_X_X_chunk (actual rows=20 loops=1)
-> Sort (actual rows=102 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1
-> Seq Scan on compress_hyper_X_X_chunk
-> Sort
Sort Key: m2."time"
Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2 (actual rows=3598 loops=1)
-> Index Scan using compress_hyper_X_X_chunk__compressed_hypertable_4_device_id__t on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1 (actual rows=4 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2
-> Index Scan using compress_hyper_X_X_chunk__compressed_hypertable_4_device_id__t on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1
Index Cond: (device_id = 2)
(20 rows)
(16 rows)
-- test implicit self-join
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM :TEST_TABLE m1,
:TEST_TABLE m2
@ -849,27 +836,24 @@ ORDER BY m1.time,
m2.device_id
LIMIT 20;
QUERY PLAN
Limit (actual rows=20 loops=1)
-> Incremental Sort (actual rows=20 loops=1)
Limit
-> Incremental Sort
Sort Key: m1."time", m1.device_id, m2.device_id
Presorted Key: m1."time"
Full-sort Groups: 1 Sort Method: quicksort
-> Merge Join (actual rows=26 loops=1)
-> Merge Join
Merge Cond: (m1."time" = m2."time")
-> Sort (actual rows=6 loops=1)
-> Sort
Sort Key: m1."time"
Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1 (actual rows=17990 loops=1)
-> Seq Scan on compress_hyper_X_X_chunk (actual rows=20 loops=1)
-> Sort (actual rows=26 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1
-> Seq Scan on compress_hyper_X_X_chunk
-> Sort
Sort Key: m2."time"
Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2 (actual rows=17990 loops=1)
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1 (actual rows=20 loops=1)
(17 rows)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1
(14 rows)
-- test self-join with sub-query
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM (
SELECT *
@ -882,24 +866,21 @@ ORDER BY m1.time,
m2.device_id
LIMIT 10;
QUERY PLAN
Limit (actual rows=10 loops=1)
-> Incremental Sort (actual rows=10 loops=1)
Limit
-> Incremental Sort
Sort Key: m1."time", m1.device_id, m2.device_id
Presorted Key: m1."time"
Full-sort Groups: 1 Sort Method: top-N heapsort
-> Merge Join (actual rows=26 loops=1)
-> Merge Join
Merge Cond: (m1."time" = m2."time")
-> Sort (actual rows=6 loops=1)
-> Sort
Sort Key: m1."time"
Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1 (actual rows=17990 loops=1)
-> Seq Scan on compress_hyper_X_X_chunk (actual rows=20 loops=1)
-> Sort (actual rows=26 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m1
-> Seq Scan on compress_hyper_X_X_chunk
-> Sort
Sort Key: m2."time"
Sort Method: quicksort
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2 (actual rows=17990 loops=1)
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1 (actual rows=20 loops=1)
(17 rows)
-> Custom Scan (DecompressChunk) on _hyper_X_X_chunk m2
-> Seq Scan on compress_hyper_X_X_chunk compress_hyper_X_X_chunk_1
(14 rows)
RESET parallel_leader_participation;
:PREFIX

17
tsl/test/shared/sql/transparent_decompress_chunk.sql.in
View File

@ -5,6 +5,7 @@
\set PREFIX 'EXPLAIN (analyze, costs off, timing off, summary off)'
\set PREFIX_VERBOSE 'EXPLAIN (analyze, costs off, timing off, summary off, verbose)'
\set PREFIX_NO_ANALYZE 'EXPLAIN (verbose, costs off)'
\set PREFIX_NO_VERBOSE 'EXPLAIN (costs off)'
SELECT show_chunks('metrics_compressed') AS "TEST_TABLE" ORDER BY 1::text LIMIT 1 \gset
@ -188,7 +189,7 @@ DROP VIEW compressed_view;
SET parallel_leader_participation TO off;
-- test INNER JOIN
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM :TEST_TABLE m1
INNER JOIN :TEST_TABLE m2 ON m1.time = m2.time
@ -197,7 +198,7 @@ FROM :TEST_TABLE m1
m1.device_id
LIMIT 10;
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM :TEST_TABLE m1
INNER JOIN :TEST_TABLE m2 ON m1.time = m2.time
@ -208,7 +209,7 @@ FROM :TEST_TABLE m1
m1.device_id
LIMIT 10;
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM :TEST_TABLE m1
INNER JOIN :TEST_TABLE m2 ON m1.time = m2.time
@ -220,7 +221,7 @@ FROM :TEST_TABLE m1
m2.device_id
LIMIT 100;
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM metrics m1
INNER JOIN metrics_space m2 ON m1.time = m2.time
@ -233,7 +234,7 @@ FROM metrics m1
LIMIT 100;
-- test OUTER JOIN
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM :TEST_TABLE m1
LEFT OUTER JOIN :TEST_TABLE m2 ON m1.time = m2.time
@ -242,7 +243,7 @@ ORDER BY m1.time,
m1.device_id
LIMIT 10;
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM :TEST_TABLE m1
LEFT OUTER JOIN :TEST_TABLE m2 ON m1.time = m2.time
@ -255,7 +256,7 @@ ORDER BY m1.time,
LIMIT 100;
-- test implicit self-join
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM :TEST_TABLE m1,
:TEST_TABLE m2
@ -267,7 +268,7 @@ ORDER BY m1.time,
LIMIT 20;
-- test self-join with sub-query
:PREFIX
:PREFIX_NO_VERBOSE
SELECT *
FROM (
SELECT *