postgres/timescaledb
1
0
Fork 0
mirror of https://github.com/timescale/timescaledb.git synced 2025-05-18 19:59:48 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix cross-platform explain output differences

Browse Source 
Enforce index scan for queries that would produce different output
between 32bit and 64bit platform to make explain output for
constraint_exclusion_prepared, ordered_append and ordered_append_join
test output consistent across platforms.
This commit is contained in:
Sven Klemm 2020-09-10 17:00:33 +02:00 committed by Sven Klemm
parent f3242fe932
commit a218532941
7 changed files with 301 additions and 463 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

138
tsl/test/shared/expected/constraint_exclusion_prepared.out
View File

@ -204,6 +204,7 @@ LIMIT 100;
DEALLOCATE prep; DEALLOCATE prep;
-- runtime exclusion with LATERAL and 2 hypertables -- runtime exclusion with LATERAL and 2 hypertables
SET enable_seqscan TO false;
PREPARE prep AS PREPARE prep AS
SELECT m1.time, SELECT m1.time,
m2.time m2.time
@ -367,6 +368,7 @@ LIMIT 100;
(25 rows) (25 rows)
DEALLOCATE prep; DEALLOCATE prep;
RESET enable_seqscan;
-- executor startup exclusion with subquery -- executor startup exclusion with subquery
PREPARE prep AS PREPARE prep AS
SELECT time SELECT time
@ -742,6 +744,7 @@ LIMIT 100;
DEALLOCATE prep; DEALLOCATE prep;
-- runtime exclusion with LATERAL and 2 hypertables -- runtime exclusion with LATERAL and 2 hypertables
SET enable_seqscan TO false;
PREPARE prep AS PREPARE prep AS
SELECT m1.time, SELECT m1.time,
m2.time m2.time
@ -995,6 +998,7 @@ LIMIT 100;
(43 rows) (43 rows)
DEALLOCATE prep; DEALLOCATE prep;
RESET enable_seqscan;
-- executor startup exclusion with subquery -- executor startup exclusion with subquery
PREPARE prep AS PREPARE prep AS
SELECT time SELECT time
@ -1585,6 +1589,7 @@ LIMIT 100;
DEALLOCATE prep; DEALLOCATE prep;
-- runtime exclusion with LATERAL and 2 hypertables -- runtime exclusion with LATERAL and 2 hypertables
SET enable_seqscan TO false;
PREPARE prep AS PREPARE prep AS
SELECT m1.time, SELECT m1.time,
m2.time m2.time
@ -1773,6 +1778,7 @@ LIMIT 100;
(30 rows) (30 rows)
DEALLOCATE prep; DEALLOCATE prep;
RESET enable_seqscan;
-- executor startup exclusion with subquery -- executor startup exclusion with subquery
PREPARE prep AS PREPARE prep AS
SELECT time SELECT time
@ -2278,6 +2284,7 @@ LIMIT 100;
DEALLOCATE prep; DEALLOCATE prep;
-- runtime exclusion with LATERAL and 2 hypertables -- runtime exclusion with LATERAL and 2 hypertables
SET enable_seqscan TO false;
PREPARE prep AS PREPARE prep AS
SELECT m1.time, SELECT m1.time,
m2.time m2.time
@ -2291,29 +2298,21 @@ WHERE device_id = 2
ORDER BY m1.time ORDER BY m1.time
LIMIT 100; LIMIT 100;
:PREFIX EXECUTE prep; :PREFIX EXECUTE prep;
QUERY PLAN QUERY PLAN
------------------------------------------------------------------------------------------------------------------ ------------------------------------------------------------------------------------------------------------------------------------------------------------------------
Limit (actual rows=100 loops=1) Limit (actual rows=100 loops=1)
-> Nested Loop Left Join (actual rows=100 loops=1) -> Nested Loop Left Join (actual rows=100 loops=1)
-> Custom Scan (ChunkAppend) on metrics_space_compressed m1 (actual rows=100 loops=1) -> Custom Scan (ChunkAppend) on metrics_space_compressed m1 (actual rows=100 loops=1)
Order: m1."time" Order: m1."time"
-> Custom Scan (DecompressChunk) on _hyper_5_20_chunk m1_1 (actual rows=100 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_20_chunk m1_1 (actual rows=100 loops=1)
-> Sort (actual rows=1 loops=1) -> Index Scan Backward using compress_hyper_6_35_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_35_chunk (actual rows=1 loops=1)
Sort Key: compress_hyper_6_35_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
Sort Method: quicksort
-> Seq Scan on compress_hyper_6_35_chunk (actual rows=4 loops=1)
Filter: (device_id = 2)
Rows Removed by Filter: 8
-> Custom Scan (DecompressChunk) on _hyper_5_23_chunk m1_2 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_23_chunk m1_2 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_32_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_32_chunk (never executed)
Sort Key: compress_hyper_6_32_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
-> Seq Scan on compress_hyper_6_32_chunk (never executed)
Filter: (device_id = 2)
-> Custom Scan (DecompressChunk) on _hyper_5_26_chunk m1_3 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_26_chunk m1_3 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_29_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_29_chunk (never executed)
Sort Key: compress_hyper_6_29_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
-> Seq Scan on compress_hyper_6_29_chunk (never executed)
Filter: (device_id = 2)
-> Limit (actual rows=1 loops=100) -> Limit (actual rows=1 loops=100)
-> Custom Scan (ChunkAppend) on metrics_space_compressed m2 (actual rows=1 loops=100) -> Custom Scan (ChunkAppend) on metrics_space_compressed m2 (actual rows=1 loops=100)
Chunks excluded during runtime: 6 Chunks excluded during runtime: 6
@ -2355,32 +2354,24 @@ LIMIT 100;
Filter: (m1."time" = "time") Filter: (m1."time" = "time")
-> Seq Scan on compress_hyper_6_28_chunk (never executed) -> Seq Scan on compress_hyper_6_28_chunk (never executed)
Filter: ((_ts_meta_min_1 <= m1."time") AND (_ts_meta_max_1 >= m1."time")) Filter: ((_ts_meta_min_1 <= m1."time") AND (_ts_meta_max_1 >= m1."time"))
(62 rows) (54 rows)
:PREFIX EXECUTE prep; :PREFIX EXECUTE prep;
QUERY PLAN QUERY PLAN
------------------------------------------------------------------------------------------------------------------ ------------------------------------------------------------------------------------------------------------------------------------------------------------------------
Limit (actual rows=100 loops=1) Limit (actual rows=100 loops=1)
-> Nested Loop Left Join (actual rows=100 loops=1) -> Nested Loop Left Join (actual rows=100 loops=1)
-> Custom Scan (ChunkAppend) on metrics_space_compressed m1 (actual rows=100 loops=1) -> Custom Scan (ChunkAppend) on metrics_space_compressed m1 (actual rows=100 loops=1)
Order: m1."time" Order: m1."time"
-> Custom Scan (DecompressChunk) on _hyper_5_20_chunk m1_1 (actual rows=100 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_20_chunk m1_1 (actual rows=100 loops=1)
-> Sort (actual rows=1 loops=1) -> Index Scan Backward using compress_hyper_6_35_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_35_chunk (actual rows=1 loops=1)
Sort Key: compress_hyper_6_35_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
Sort Method: quicksort
-> Seq Scan on compress_hyper_6_35_chunk (actual rows=4 loops=1)
Filter: (device_id = 2)
Rows Removed by Filter: 8
-> Custom Scan (DecompressChunk) on _hyper_5_23_chunk m1_2 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_23_chunk m1_2 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_32_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_32_chunk (never executed)
Sort Key: compress_hyper_6_32_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
-> Seq Scan on compress_hyper_6_32_chunk (never executed)
Filter: (device_id = 2)
-> Custom Scan (DecompressChunk) on _hyper_5_26_chunk m1_3 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_26_chunk m1_3 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_29_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_29_chunk (never executed)
Sort Key: compress_hyper_6_29_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
-> Seq Scan on compress_hyper_6_29_chunk (never executed)
Filter: (device_id = 2)
-> Limit (actual rows=1 loops=100) -> Limit (actual rows=1 loops=100)
-> Custom Scan (ChunkAppend) on metrics_space_compressed m2 (actual rows=1 loops=100) -> Custom Scan (ChunkAppend) on metrics_space_compressed m2 (actual rows=1 loops=100)
Chunks excluded during runtime: 6 Chunks excluded during runtime: 6
@ -2422,32 +2413,24 @@ LIMIT 100;
Filter: (m1."time" = "time") Filter: (m1."time" = "time")
-> Seq Scan on compress_hyper_6_28_chunk (never executed) -> Seq Scan on compress_hyper_6_28_chunk (never executed)
Filter: ((_ts_meta_min_1 <= m1."time") AND (_ts_meta_max_1 >= m1."time")) Filter: ((_ts_meta_min_1 <= m1."time") AND (_ts_meta_max_1 >= m1."time"))
(62 rows) (54 rows)
:PREFIX EXECUTE prep; :PREFIX EXECUTE prep;
QUERY PLAN QUERY PLAN
------------------------------------------------------------------------------------------------------------------ ------------------------------------------------------------------------------------------------------------------------------------------------------------------------
Limit (actual rows=100 loops=1) Limit (actual rows=100 loops=1)
-> Nested Loop Left Join (actual rows=100 loops=1) -> Nested Loop Left Join (actual rows=100 loops=1)
-> Custom Scan (ChunkAppend) on metrics_space_compressed m1 (actual rows=100 loops=1) -> Custom Scan (ChunkAppend) on metrics_space_compressed m1 (actual rows=100 loops=1)
Order: m1."time" Order: m1."time"
-> Custom Scan (DecompressChunk) on _hyper_5_20_chunk m1_1 (actual rows=100 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_20_chunk m1_1 (actual rows=100 loops=1)
-> Sort (actual rows=1 loops=1) -> Index Scan Backward using compress_hyper_6_35_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_35_chunk (actual rows=1 loops=1)
Sort Key: compress_hyper_6_35_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
Sort Method: quicksort
-> Seq Scan on compress_hyper_6_35_chunk (actual rows=4 loops=1)
Filter: (device_id = 2)
Rows Removed by Filter: 8
-> Custom Scan (DecompressChunk) on _hyper_5_23_chunk m1_2 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_23_chunk m1_2 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_32_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_32_chunk (never executed)
Sort Key: compress_hyper_6_32_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
-> Seq Scan on compress_hyper_6_32_chunk (never executed)
Filter: (device_id = 2)
-> Custom Scan (DecompressChunk) on _hyper_5_26_chunk m1_3 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_26_chunk m1_3 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_29_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_29_chunk (never executed)
Sort Key: compress_hyper_6_29_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
-> Seq Scan on compress_hyper_6_29_chunk (never executed)
Filter: (device_id = 2)
-> Limit (actual rows=1 loops=100) -> Limit (actual rows=1 loops=100)
-> Custom Scan (ChunkAppend) on metrics_space_compressed m2 (actual rows=1 loops=100) -> Custom Scan (ChunkAppend) on metrics_space_compressed m2 (actual rows=1 loops=100)
Chunks excluded during runtime: 6 Chunks excluded during runtime: 6
@ -2489,32 +2472,24 @@ LIMIT 100;
Filter: (m1."time" = "time") Filter: (m1."time" = "time")
-> Seq Scan on compress_hyper_6_28_chunk (never executed) -> Seq Scan on compress_hyper_6_28_chunk (never executed)
Filter: ((_ts_meta_min_1 <= m1."time") AND (_ts_meta_max_1 >= m1."time")) Filter: ((_ts_meta_min_1 <= m1."time") AND (_ts_meta_max_1 >= m1."time"))
(62 rows) (54 rows)
:PREFIX EXECUTE prep; :PREFIX EXECUTE prep;
QUERY PLAN QUERY PLAN
------------------------------------------------------------------------------------------------------------------ ------------------------------------------------------------------------------------------------------------------------------------------------------------------------
Limit (actual rows=100 loops=1) Limit (actual rows=100 loops=1)
-> Nested Loop Left Join (actual rows=100 loops=1) -> Nested Loop Left Join (actual rows=100 loops=1)
-> Custom Scan (ChunkAppend) on metrics_space_compressed m1 (actual rows=100 loops=1) -> Custom Scan (ChunkAppend) on metrics_space_compressed m1 (actual rows=100 loops=1)
Order: m1."time" Order: m1."time"
-> Custom Scan (DecompressChunk) on _hyper_5_20_chunk m1_1 (actual rows=100 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_20_chunk m1_1 (actual rows=100 loops=1)
-> Sort (actual rows=1 loops=1) -> Index Scan Backward using compress_hyper_6_35_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_35_chunk (actual rows=1 loops=1)
Sort Key: compress_hyper_6_35_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
Sort Method: quicksort
-> Seq Scan on compress_hyper_6_35_chunk (actual rows=4 loops=1)
Filter: (device_id = 2)
Rows Removed by Filter: 8
-> Custom Scan (DecompressChunk) on _hyper_5_23_chunk m1_2 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_23_chunk m1_2 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_32_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_32_chunk (never executed)
Sort Key: compress_hyper_6_32_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
-> Seq Scan on compress_hyper_6_32_chunk (never executed)
Filter: (device_id = 2)
-> Custom Scan (DecompressChunk) on _hyper_5_26_chunk m1_3 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_26_chunk m1_3 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_29_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_29_chunk (never executed)
Sort Key: compress_hyper_6_29_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
-> Seq Scan on compress_hyper_6_29_chunk (never executed)
Filter: (device_id = 2)
-> Limit (actual rows=1 loops=100) -> Limit (actual rows=1 loops=100)
-> Custom Scan (ChunkAppend) on metrics_space_compressed m2 (actual rows=1 loops=100) -> Custom Scan (ChunkAppend) on metrics_space_compressed m2 (actual rows=1 loops=100)
Chunks excluded during runtime: 6 Chunks excluded during runtime: 6
@ -2556,32 +2531,24 @@ LIMIT 100;
Filter: (m1."time" = "time") Filter: (m1."time" = "time")
-> Seq Scan on compress_hyper_6_28_chunk (never executed) -> Seq Scan on compress_hyper_6_28_chunk (never executed)
Filter: ((_ts_meta_min_1 <= m1."time") AND (_ts_meta_max_1 >= m1."time")) Filter: ((_ts_meta_min_1 <= m1."time") AND (_ts_meta_max_1 >= m1."time"))
(62 rows) (54 rows)
:PREFIX EXECUTE prep; :PREFIX EXECUTE prep;
QUERY PLAN QUERY PLAN
------------------------------------------------------------------------------------------------------------------ ------------------------------------------------------------------------------------------------------------------------------------------------------------------------
Limit (actual rows=100 loops=1) Limit (actual rows=100 loops=1)
-> Nested Loop Left Join (actual rows=100 loops=1) -> Nested Loop Left Join (actual rows=100 loops=1)
-> Custom Scan (ChunkAppend) on metrics_space_compressed m1 (actual rows=100 loops=1) -> Custom Scan (ChunkAppend) on metrics_space_compressed m1 (actual rows=100 loops=1)
Order: m1."time" Order: m1."time"
-> Custom Scan (DecompressChunk) on _hyper_5_20_chunk m1_1 (actual rows=100 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_20_chunk m1_1 (actual rows=100 loops=1)
-> Sort (actual rows=1 loops=1) -> Index Scan Backward using compress_hyper_6_35_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_35_chunk (actual rows=1 loops=1)
Sort Key: compress_hyper_6_35_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
Sort Method: quicksort
-> Seq Scan on compress_hyper_6_35_chunk (actual rows=4 loops=1)
Filter: (device_id = 2)
Rows Removed by Filter: 8
-> Custom Scan (DecompressChunk) on _hyper_5_23_chunk m1_2 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_23_chunk m1_2 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_32_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_32_chunk (never executed)
Sort Key: compress_hyper_6_32_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
-> Seq Scan on compress_hyper_6_32_chunk (never executed)
Filter: (device_id = 2)
-> Custom Scan (DecompressChunk) on _hyper_5_26_chunk m1_3 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_26_chunk m1_3 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_29_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_29_chunk (never executed)
Sort Key: compress_hyper_6_29_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
-> Seq Scan on compress_hyper_6_29_chunk (never executed)
Filter: (device_id = 2)
-> Limit (actual rows=1 loops=100) -> Limit (actual rows=1 loops=100)
-> Custom Scan (ChunkAppend) on metrics_space_compressed m2 (actual rows=1 loops=100) -> Custom Scan (ChunkAppend) on metrics_space_compressed m2 (actual rows=1 loops=100)
Chunks excluded during runtime: 6 Chunks excluded during runtime: 6
@ -2623,9 +2590,10 @@ LIMIT 100;
Filter: (m1."time" = "time") Filter: (m1."time" = "time")
-> Seq Scan on compress_hyper_6_28_chunk (never executed) -> Seq Scan on compress_hyper_6_28_chunk (never executed)
Filter: ((_ts_meta_min_1 <= m1."time") AND (_ts_meta_max_1 >= m1."time")) Filter: ((_ts_meta_min_1 <= m1."time") AND (_ts_meta_max_1 >= m1."time"))
(62 rows) (54 rows)
DEALLOCATE prep; DEALLOCATE prep;
RESET enable_seqscan;
-- executor startup exclusion with subquery -- executor startup exclusion with subquery
PREPARE prep AS PREPARE prep AS
SELECT time SELECT time

35
tsl/test/shared/expected/ordered_append-11.out
View File

@ -186,6 +186,7 @@ LIMIT 1;
-- test equality constraint on ORDER BY prefix -- test equality constraint on ORDER BY prefix
-- currently not optimized -- currently not optimized
SET enable_seqscan TO false;
:PREFIX :PREFIX
SELECT time, SELECT time,
device_id device_id
@ -210,6 +211,7 @@ LIMIT 10;
Heap Fetches: 1 Heap Fetches: 1
(12 rows) (12 rows)
RESET enable_seqscan;
-- queries without LIMIT should use ordered append -- queries without LIMIT should use ordered append
:PREFIX :PREFIX
SELECT time SELECT time
@ -1060,6 +1062,7 @@ LIMIT 1;
-- test equality constraint on ORDER BY prefix -- test equality constraint on ORDER BY prefix
-- currently not optimized -- currently not optimized
SET enable_seqscan TO false;
:PREFIX :PREFIX
SELECT time, SELECT time,
device_id device_id
@ -1081,6 +1084,7 @@ LIMIT 10;
Filter: (device_id = 1) Filter: (device_id = 1)
(9 rows) (9 rows)
RESET enable_seqscan;
-- queries without LIMIT should use ordered append -- queries without LIMIT should use ordered append
:PREFIX :PREFIX
SELECT time SELECT time
@ -2355,6 +2359,7 @@ LIMIT 1;
-- test equality constraint on ORDER BY prefix -- test equality constraint on ORDER BY prefix
-- currently not optimized -- currently not optimized
SET enable_seqscan TO false;
:PREFIX :PREFIX
SELECT time, SELECT time,
device_id device_id
@ -2379,6 +2384,7 @@ LIMIT 10;
Index Cond: (device_id = 1) Index Cond: (device_id = 1)
(12 rows) (12 rows)
RESET enable_seqscan;
-- queries without LIMIT should use ordered append -- queries without LIMIT should use ordered append
:PREFIX :PREFIX
SELECT time SELECT time
@ -3340,6 +3346,7 @@ LIMIT 1;
-- test equality constraint on ORDER BY prefix -- test equality constraint on ORDER BY prefix
-- currently not optimized -- currently not optimized
SET enable_seqscan TO false;
:PREFIX :PREFIX
SELECT time, SELECT time,
device_id device_id
@ -3348,31 +3355,23 @@ WHERE device_id = 1
ORDER BY device_id, ORDER BY device_id,
time time
LIMIT 10; LIMIT 10;
QUERY PLAN QUERY PLAN
----------------------------------------------------------------------------------------- ------------------------------------------------------------------------------------------------------------------------------------------------------------------
Limit (actual rows=10 loops=1) Limit (actual rows=10 loops=1)
-> Merge Append (actual rows=10 loops=1) -> Merge Append (actual rows=10 loops=1)
Sort Key: _hyper_5_25_chunk."time" Sort Key: _hyper_5_25_chunk."time"
-> Custom Scan (DecompressChunk) on _hyper_5_25_chunk (actual rows=1 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_25_chunk (actual rows=1 loops=1)
-> Sort (actual rows=1 loops=1) -> Index Scan Backward using compress_hyper_6_30_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_30_chunk (actual rows=1 loops=1)
Sort Key: compress_hyper_6_30_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
Sort Method: quicksort
-> Seq Scan on compress_hyper_6_30_chunk (actual rows=6 loops=1)
Filter: (device_id = 1)
-> Custom Scan (DecompressChunk) on _hyper_5_19_chunk (actual rows=10 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_19_chunk (actual rows=10 loops=1)
-> Sort (actual rows=1 loops=1) -> Index Scan Backward using compress_hyper_6_36_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_36_chunk (actual rows=1 loops=1)
Sort Key: compress_hyper_6_36_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
Sort Method: quicksort
-> Seq Scan on compress_hyper_6_36_chunk (actual rows=4 loops=1)
Filter: (device_id = 1)
-> Custom Scan (DecompressChunk) on _hyper_5_22_chunk (actual rows=1 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_22_chunk (actual rows=1 loops=1)
-> Sort (actual rows=1 loops=1) -> Index Scan Backward using compress_hyper_6_33_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_33_chunk (actual rows=1 loops=1)
Sort Key: compress_hyper_6_33_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
Sort Method: quicksort (12 rows)
-> Seq Scan on compress_hyper_6_33_chunk (actual rows=6 loops=1)
Filter: (device_id = 1)
(21 rows)
RESET enable_seqscan;
-- queries without LIMIT should use ordered append -- queries without LIMIT should use ordered append
:PREFIX :PREFIX
SELECT time SELECT time

35
tsl/test/shared/expected/ordered_append-12.out
View File

@ -186,6 +186,7 @@ LIMIT 1;
-- test equality constraint on ORDER BY prefix -- test equality constraint on ORDER BY prefix
-- currently not optimized -- currently not optimized
SET enable_seqscan TO false;
:PREFIX :PREFIX
SELECT time, SELECT time,
device_id device_id
@ -210,6 +211,7 @@ LIMIT 10;
Heap Fetches: 1 Heap Fetches: 1
(12 rows) (12 rows)
RESET enable_seqscan;
-- queries without LIMIT should use ordered append -- queries without LIMIT should use ordered append
:PREFIX :PREFIX
SELECT time SELECT time
@ -1053,6 +1055,7 @@ LIMIT 1;
-- test equality constraint on ORDER BY prefix -- test equality constraint on ORDER BY prefix
-- currently not optimized -- currently not optimized
SET enable_seqscan TO false;
:PREFIX :PREFIX
SELECT time, SELECT time,
device_id device_id
@ -1074,6 +1077,7 @@ LIMIT 10;
Filter: (device_id = 1) Filter: (device_id = 1)
(9 rows) (9 rows)
RESET enable_seqscan;
-- queries without LIMIT should use ordered append -- queries without LIMIT should use ordered append
:PREFIX :PREFIX
SELECT time SELECT time
@ -2356,6 +2360,7 @@ LIMIT 1;
-- test equality constraint on ORDER BY prefix -- test equality constraint on ORDER BY prefix
-- currently not optimized -- currently not optimized
SET enable_seqscan TO false;
:PREFIX :PREFIX
SELECT time, SELECT time,
device_id device_id
@ -2380,6 +2385,7 @@ LIMIT 10;
Index Cond: (device_id = 1) Index Cond: (device_id = 1)
(12 rows) (12 rows)
RESET enable_seqscan;
-- queries without LIMIT should use ordered append -- queries without LIMIT should use ordered append
:PREFIX :PREFIX
SELECT time SELECT time
@ -3342,6 +3348,7 @@ LIMIT 1;
-- test equality constraint on ORDER BY prefix -- test equality constraint on ORDER BY prefix
-- currently not optimized -- currently not optimized
SET enable_seqscan TO false;
:PREFIX :PREFIX
SELECT time, SELECT time,
device_id device_id
@ -3350,31 +3357,23 @@ WHERE device_id = 1
ORDER BY device_id, ORDER BY device_id,
time time
LIMIT 10; LIMIT 10;
QUERY PLAN QUERY PLAN
----------------------------------------------------------------------------------------- ------------------------------------------------------------------------------------------------------------------------------------------------------------------
Limit (actual rows=10 loops=1) Limit (actual rows=10 loops=1)
-> Merge Append (actual rows=10 loops=1) -> Merge Append (actual rows=10 loops=1)
Sort Key: _hyper_5_25_chunk."time" Sort Key: _hyper_5_25_chunk."time"
-> Custom Scan (DecompressChunk) on _hyper_5_25_chunk (actual rows=1 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_25_chunk (actual rows=1 loops=1)
-> Sort (actual rows=1 loops=1) -> Index Scan Backward using compress_hyper_6_30_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_30_chunk (actual rows=1 loops=1)
Sort Key: compress_hyper_6_30_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
Sort Method: quicksort
-> Seq Scan on compress_hyper_6_30_chunk (actual rows=6 loops=1)
Filter: (device_id = 1)
-> Custom Scan (DecompressChunk) on _hyper_5_19_chunk (actual rows=10 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_19_chunk (actual rows=10 loops=1)
-> Sort (actual rows=1 loops=1) -> Index Scan Backward using compress_hyper_6_36_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_36_chunk (actual rows=1 loops=1)
Sort Key: compress_hyper_6_36_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
Sort Method: quicksort
-> Seq Scan on compress_hyper_6_36_chunk (actual rows=4 loops=1)
Filter: (device_id = 1)
-> Custom Scan (DecompressChunk) on _hyper_5_22_chunk (actual rows=1 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_22_chunk (actual rows=1 loops=1)
-> Sort (actual rows=1 loops=1) -> Index Scan Backward using compress_hyper_6_33_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_33_chunk (actual rows=1 loops=1)
Sort Key: compress_hyper_6_33_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
Sort Method: quicksort (12 rows)
-> Seq Scan on compress_hyper_6_33_chunk (actual rows=6 loops=1)
Filter: (device_id = 1)
(21 rows)
RESET enable_seqscan;
-- queries without LIMIT should use ordered append -- queries without LIMIT should use ordered append
:PREFIX :PREFIX
SELECT time SELECT time

546
tsl/test/shared/expected/ordered_append_join.out
View File

@ -365,6 +365,7 @@ ORDER BY time;
(28 rows) (28 rows)
RESET enable_hashjoin; RESET enable_hashjoin;
SET enable_seqscan TO false;
-- test JOIN on time column -- test JOIN on time column
-- should use 2 ChunkAppend -- should use 2 ChunkAppend
:PREFIX :PREFIX
@ -829,6 +830,7 @@ LIMIT 100;
Heap Fetches: 0 Heap Fetches: 0
(40 rows) (40 rows)
RESET enable_seqscan;
\set TEST_TABLE 'metrics_space' \set TEST_TABLE 'metrics_space'
\ir :TEST_QUERY_NAME \ir :TEST_QUERY_NAME
-- This file and its contents are licensed under the Timescale License. -- This file and its contents are licensed under the Timescale License.
@ -1388,6 +1390,7 @@ ORDER BY time;
(52 rows) (52 rows)
RESET enable_hashjoin; RESET enable_hashjoin;
SET enable_seqscan TO false;
-- test JOIN on time column -- test JOIN on time column
-- should use 2 ChunkAppend -- should use 2 ChunkAppend
:PREFIX :PREFIX
@ -1730,8 +1733,8 @@ FROM :TEST_TABLE o1
WHERE o1.device_id = 1 WHERE o1.device_id = 1
ORDER BY o1.time ORDER BY o1.time
LIMIT 100; LIMIT 100;
QUERY PLAN QUERY PLAN
----------------------------------------------------------------------------------------------------------------------------- ----------------------------------------------------------------------------------------------------------------------------------------------------
Limit (actual rows=100 loops=1) Limit (actual rows=100 loops=1)
-> Nested Loop (actual rows=100 loops=1) -> Nested Loop (actual rows=100 loops=1)
-> Custom Scan (ChunkAppend) on metrics_space o1 (actual rows=1 loops=1) -> Custom Scan (ChunkAppend) on metrics_space o1 (actual rows=1 loops=1)
@ -1744,13 +1747,16 @@ LIMIT 100;
Filter: (device_id = 1) Filter: (device_id = 1)
-> Materialize (actual rows=100 loops=1) -> Materialize (actual rows=100 loops=1)
-> Append (actual rows=100 loops=1) -> Append (actual rows=100 loops=1)
-> Seq Scan on _hyper_2_10_chunk o2 (actual rows=100 loops=1) -> Index Only Scan using _hyper_2_10_chunk_metrics_space_device_id_time_idx on _hyper_2_10_chunk o2 (actual rows=100 loops=1)
Filter: (device_id = 1) Index Cond: (device_id = 1)
-> Seq Scan on _hyper_2_4_chunk o2_1 (never executed) Heap Fetches: 100
Filter: (device_id = 1) -> Index Only Scan using _hyper_2_4_chunk_metrics_space_device_id_time_idx on _hyper_2_4_chunk o2_1 (never executed)
-> Seq Scan on _hyper_2_7_chunk o2_2 (never executed) Index Cond: (device_id = 1)
Filter: (device_id = 1) Heap Fetches: 0
(18 rows) -> Index Only Scan using _hyper_2_7_chunk_metrics_space_device_id_time_idx on _hyper_2_7_chunk o2_2 (never executed)
Index Cond: (device_id = 1)
Heap Fetches: 0
(21 rows)
-- test JOIN on time column with implicit join -- test JOIN on time column with implicit join
-- should use 2 ChunkAppend -- should use 2 ChunkAppend
@ -1840,6 +1846,7 @@ LIMIT 100;
Heap Fetches: 0 Heap Fetches: 0
(34 rows) (34 rows)
RESET enable_seqscan;
\set TEST_TABLE 'metrics_compressed' \set TEST_TABLE 'metrics_compressed'
\ir :TEST_QUERY_NAME \ir :TEST_QUERY_NAME
-- This file and its contents are licensed under the Timescale License. -- This file and its contents are licensed under the Timescale License.
@ -2239,6 +2246,7 @@ ORDER BY time;
(24 rows) (24 rows)
RESET enable_hashjoin; RESET enable_hashjoin;
SET enable_seqscan TO false;
-- test JOIN on time column -- test JOIN on time column
-- should use 2 ChunkAppend -- should use 2 ChunkAppend
:PREFIX :PREFIX
@ -2549,8 +2557,8 @@ FROM :TEST_TABLE o1
AND o1.time = o2.time AND o1.time = o2.time
ORDER BY o1.time ORDER BY o1.time
LIMIT 100; LIMIT 100;
QUERY PLAN QUERY PLAN
-------------------------------------------------------------------------------------------------------------------------- --------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
Limit (actual rows=100 loops=1) Limit (actual rows=100 loops=1)
-> Merge Join (actual rows=100 loops=1) -> Merge Join (actual rows=100 loops=1)
Merge Cond: ((o1."time" = o2."time") AND (o1.device_id = o2.device_id)) Merge Cond: ((o1."time" = o2."time") AND (o1.device_id = o2.device_id))
@ -2559,21 +2567,21 @@ FROM :TEST_TABLE o1
Sort Method: quicksort Sort Method: quicksort
-> Append (actual rows=68370 loops=1) -> Append (actual rows=68370 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_3_13_chunk o1 (actual rows=17990 loops=1) -> Custom Scan (DecompressChunk) on _hyper_3_13_chunk o1 (actual rows=17990 loops=1)
-> Seq Scan on compress_hyper_4_18_chunk (actual rows=20 loops=1) -> Index Scan using compress_hyper_4_18_chunk__compressed_hypertable_4_device_id__t on compress_hyper_4_18_chunk (actual rows=20 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_3_14_chunk o1_1 (actual rows=25190 loops=1) -> Custom Scan (DecompressChunk) on _hyper_3_14_chunk o1_1 (actual rows=25190 loops=1)
-> Seq Scan on compress_hyper_4_17_chunk (actual rows=30 loops=1) -> Index Scan using compress_hyper_4_17_chunk__compressed_hypertable_4_device_id__t on compress_hyper_4_17_chunk (actual rows=30 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_3_15_chunk o1_2 (actual rows=25190 loops=1) -> Custom Scan (DecompressChunk) on _hyper_3_15_chunk o1_2 (actual rows=25190 loops=1)
-> Seq Scan on compress_hyper_4_16_chunk (actual rows=30 loops=1) -> Index Scan using compress_hyper_4_16_chunk__compressed_hypertable_4_device_id__t on compress_hyper_4_16_chunk (actual rows=30 loops=1)
-> Sort (actual rows=100 loops=1) -> Sort (actual rows=100 loops=1)
Sort Key: o2."time", o2.device_id Sort Key: o2."time", o2.device_id
Sort Method: quicksort Sort Method: quicksort
-> Append (actual rows=68370 loops=1) -> Append (actual rows=68370 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_3_13_chunk o2 (actual rows=17990 loops=1) -> Custom Scan (DecompressChunk) on _hyper_3_13_chunk o2 (actual rows=17990 loops=1)
-> Seq Scan on compress_hyper_4_18_chunk compress_hyper_4_18_chunk_1 (actual rows=20 loops=1) -> Index Scan using compress_hyper_4_18_chunk__compressed_hypertable_4_device_id__t on compress_hyper_4_18_chunk compress_hyper_4_18_chunk_1 (actual rows=20 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_3_14_chunk o2_1 (actual rows=25190 loops=1) -> Custom Scan (DecompressChunk) on _hyper_3_14_chunk o2_1 (actual rows=25190 loops=1)
-> Seq Scan on compress_hyper_4_17_chunk compress_hyper_4_17_chunk_1 (actual rows=30 loops=1) -> Index Scan using compress_hyper_4_17_chunk__compressed_hypertable_4_device_id__t on compress_hyper_4_17_chunk compress_hyper_4_17_chunk_1 (actual rows=30 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_3_15_chunk o2_2 (actual rows=25190 loops=1) -> Custom Scan (DecompressChunk) on _hyper_3_15_chunk o2_2 (actual rows=25190 loops=1)
-> Seq Scan on compress_hyper_4_16_chunk compress_hyper_4_16_chunk_1 (actual rows=30 loops=1) -> Index Scan using compress_hyper_4_16_chunk__compressed_hypertable_4_device_id__t on compress_hyper_4_16_chunk compress_hyper_4_16_chunk_1 (actual rows=30 loops=1)
(23 rows) (23 rows)
-- test JOIN on device_id -- test JOIN on device_id
@ -2710,6 +2718,7 @@ LIMIT 100;
Index Cond: (device_id = 2) Index Cond: (device_id = 2)
(40 rows) (40 rows)
RESET enable_seqscan;
\set TEST_TABLE 'metrics_space_compressed' \set TEST_TABLE 'metrics_space_compressed'
\ir :TEST_QUERY_NAME \ir :TEST_QUERY_NAME
-- This file and its contents are licensed under the Timescale License. -- This file and its contents are licensed under the Timescale License.
@ -3351,6 +3360,7 @@ ORDER BY time;
(36 rows) (36 rows)
RESET enable_hashjoin; RESET enable_hashjoin;
SET enable_seqscan TO false;
-- test JOIN on time column -- test JOIN on time column
-- should use 2 ChunkAppend -- should use 2 ChunkAppend
:PREFIX :PREFIX
@ -3361,50 +3371,35 @@ WHERE o1.device_id = 1
AND o2.device_id = 2 AND o2.device_id = 2
ORDER BY o1.time ORDER BY o1.time
LIMIT 100; LIMIT 100;
QUERY PLAN QUERY PLAN
----------------------------------------------------------------------------------------------------------- ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
Limit (actual rows=100 loops=1) Limit (actual rows=100 loops=1)
-> Merge Join (actual rows=100 loops=1) -> Merge Join (actual rows=100 loops=1)
Merge Cond: (o1."time" = o2."time") Merge Cond: (o1."time" = o2."time")
-> Custom Scan (ChunkAppend) on metrics_space_compressed o1 (actual rows=100 loops=1) -> Custom Scan (ChunkAppend) on metrics_space_compressed o1 (actual rows=100 loops=1)
Order: o1."time" Order: o1."time"
-> Custom Scan (DecompressChunk) on _hyper_5_19_chunk o1_1 (actual rows=100 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_19_chunk o1_1 (actual rows=100 loops=1)
-> Sort (actual rows=1 loops=1) -> Index Scan Backward using compress_hyper_6_36_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_36_chunk (actual rows=1 loops=1)
Sort Key: compress_hyper_6_36_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
Sort Method: quicksort
-> Seq Scan on compress_hyper_6_36_chunk (actual rows=4 loops=1)
Filter: (device_id = 1)
-> Custom Scan (DecompressChunk) on _hyper_5_22_chunk o1_2 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_22_chunk o1_2 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_33_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_33_chunk (never executed)
Sort Key: compress_hyper_6_33_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
-> Seq Scan on compress_hyper_6_33_chunk (never executed)
Filter: (device_id = 1)
-> Custom Scan (DecompressChunk) on _hyper_5_25_chunk o1_3 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_25_chunk o1_3 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_30_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_30_chunk (never executed)
Sort Key: compress_hyper_6_30_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
-> Seq Scan on compress_hyper_6_30_chunk (never executed)
Filter: (device_id = 1)
-> Materialize (actual rows=100 loops=1) -> Materialize (actual rows=100 loops=1)
-> Custom Scan (ChunkAppend) on metrics_space_compressed o2 (actual rows=100 loops=1) -> Custom Scan (ChunkAppend) on metrics_space_compressed o2 (actual rows=100 loops=1)
Order: o2."time" Order: o2."time"
-> Custom Scan (DecompressChunk) on _hyper_5_20_chunk o2_1 (actual rows=100 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_20_chunk o2_1 (actual rows=100 loops=1)
-> Sort (actual rows=1 loops=1) -> Index Scan Backward using compress_hyper_6_35_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_35_chunk (actual rows=1 loops=1)
Sort Key: compress_hyper_6_35_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
Sort Method: quicksort
-> Seq Scan on compress_hyper_6_35_chunk (actual rows=4 loops=1)
Filter: (device_id = 2)
Rows Removed by Filter: 8
-> Custom Scan (DecompressChunk) on _hyper_5_23_chunk o2_2 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_23_chunk o2_2 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_32_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_32_chunk (never executed)
Sort Key: compress_hyper_6_32_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
-> Seq Scan on compress_hyper_6_32_chunk (never executed)
Filter: (device_id = 2)
-> Custom Scan (DecompressChunk) on _hyper_5_26_chunk o2_3 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_26_chunk o2_3 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_29_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_29_chunk (never executed)
Sort Key: compress_hyper_6_29_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
-> Seq Scan on compress_hyper_6_29_chunk (never executed) (26 rows)
Filter: (device_id = 2)
(41 rows)
-- test JOIN on time column with USING -- test JOIN on time column with USING
-- should use 2 ChunkAppend -- should use 2 ChunkAppend
@ -3416,50 +3411,35 @@ WHERE o1.device_id = 1
AND o2.device_id = 2 AND o2.device_id = 2
ORDER BY o1.time ORDER BY o1.time
LIMIT 100; LIMIT 100;
QUERY PLAN QUERY PLAN
----------------------------------------------------------------------------------------------------------- ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
Limit (actual rows=100 loops=1) Limit (actual rows=100 loops=1)
-> Merge Join (actual rows=100 loops=1) -> Merge Join (actual rows=100 loops=1)
Merge Cond: (o1."time" = o2."time") Merge Cond: (o1."time" = o2."time")
-> Custom Scan (ChunkAppend) on metrics_space_compressed o1 (actual rows=100 loops=1) -> Custom Scan (ChunkAppend) on metrics_space_compressed o1 (actual rows=100 loops=1)
Order: o1."time" Order: o1."time"
-> Custom Scan (DecompressChunk) on _hyper_5_19_chunk o1_1 (actual rows=100 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_19_chunk o1_1 (actual rows=100 loops=1)
-> Sort (actual rows=1 loops=1) -> Index Scan Backward using compress_hyper_6_36_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_36_chunk (actual rows=1 loops=1)
Sort Key: compress_hyper_6_36_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
Sort Method: quicksort
-> Seq Scan on compress_hyper_6_36_chunk (actual rows=4 loops=1)
Filter: (device_id = 1)
-> Custom Scan (DecompressChunk) on _hyper_5_22_chunk o1_2 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_22_chunk o1_2 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_33_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_33_chunk (never executed)
Sort Key: compress_hyper_6_33_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
-> Seq Scan on compress_hyper_6_33_chunk (never executed)
Filter: (device_id = 1)
-> Custom Scan (DecompressChunk) on _hyper_5_25_chunk o1_3 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_25_chunk o1_3 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_30_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_30_chunk (never executed)
Sort Key: compress_hyper_6_30_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
-> Seq Scan on compress_hyper_6_30_chunk (never executed)
Filter: (device_id = 1)
-> Materialize (actual rows=100 loops=1) -> Materialize (actual rows=100 loops=1)
-> Custom Scan (ChunkAppend) on metrics_space_compressed o2 (actual rows=100 loops=1) -> Custom Scan (ChunkAppend) on metrics_space_compressed o2 (actual rows=100 loops=1)
Order: o2."time" Order: o2."time"
-> Custom Scan (DecompressChunk) on _hyper_5_20_chunk o2_1 (actual rows=100 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_20_chunk o2_1 (actual rows=100 loops=1)
-> Sort (actual rows=1 loops=1) -> Index Scan Backward using compress_hyper_6_35_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_35_chunk (actual rows=1 loops=1)
Sort Key: compress_hyper_6_35_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
Sort Method: quicksort
-> Seq Scan on compress_hyper_6_35_chunk (actual rows=4 loops=1)
Filter: (device_id = 2)
Rows Removed by Filter: 8
-> Custom Scan (DecompressChunk) on _hyper_5_23_chunk o2_2 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_23_chunk o2_2 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_32_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_32_chunk (never executed)
Sort Key: compress_hyper_6_32_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
-> Seq Scan on compress_hyper_6_32_chunk (never executed)
Filter: (device_id = 2)
-> Custom Scan (DecompressChunk) on _hyper_5_26_chunk o2_3 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_26_chunk o2_3 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_29_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_29_chunk (never executed)
Sort Key: compress_hyper_6_29_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
-> Seq Scan on compress_hyper_6_29_chunk (never executed) (26 rows)
Filter: (device_id = 2)
(41 rows)
-- test NATURAL JOIN on time column -- test NATURAL JOIN on time column
-- should use 2 ChunkAppend -- should use 2 ChunkAppend
@ -3491,50 +3471,35 @@ WHERE o1.device_id = 1
AND o2.device_id = 2 AND o2.device_id = 2
ORDER BY o1.time ORDER BY o1.time
LIMIT 100; LIMIT 100;
QUERY PLAN QUERY PLAN
----------------------------------------------------------------------------------------------------------- ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
Limit (actual rows=100 loops=1) Limit (actual rows=100 loops=1)
-> Merge Join (actual rows=100 loops=1) -> Merge Join (actual rows=100 loops=1)
Merge Cond: (o1."time" = o2."time") Merge Cond: (o1."time" = o2."time")
-> Custom Scan (ChunkAppend) on metrics_space_compressed o1 (actual rows=100 loops=1) -> Custom Scan (ChunkAppend) on metrics_space_compressed o1 (actual rows=100 loops=1)
Order: o1."time" Order: o1."time"
-> Custom Scan (DecompressChunk) on _hyper_5_19_chunk o1_1 (actual rows=100 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_19_chunk o1_1 (actual rows=100 loops=1)
-> Sort (actual rows=1 loops=1) -> Index Scan Backward using compress_hyper_6_36_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_36_chunk (actual rows=1 loops=1)
Sort Key: compress_hyper_6_36_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
Sort Method: quicksort
-> Seq Scan on compress_hyper_6_36_chunk (actual rows=4 loops=1)
Filter: (device_id = 1)
-> Custom Scan (DecompressChunk) on _hyper_5_22_chunk o1_2 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_22_chunk o1_2 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_33_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_33_chunk (never executed)
Sort Key: compress_hyper_6_33_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
-> Seq Scan on compress_hyper_6_33_chunk (never executed)
Filter: (device_id = 1)
-> Custom Scan (DecompressChunk) on _hyper_5_25_chunk o1_3 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_25_chunk o1_3 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_30_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_30_chunk (never executed)
Sort Key: compress_hyper_6_30_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
-> Seq Scan on compress_hyper_6_30_chunk (never executed)
Filter: (device_id = 1)
-> Materialize (actual rows=100 loops=1) -> Materialize (actual rows=100 loops=1)
-> Custom Scan (ChunkAppend) on metrics_space_compressed o2 (actual rows=100 loops=1) -> Custom Scan (ChunkAppend) on metrics_space_compressed o2 (actual rows=100 loops=1)
Order: o2."time" Order: o2."time"
-> Custom Scan (DecompressChunk) on _hyper_5_20_chunk o2_1 (actual rows=100 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_20_chunk o2_1 (actual rows=100 loops=1)
-> Sort (actual rows=1 loops=1) -> Index Scan Backward using compress_hyper_6_35_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_35_chunk (actual rows=1 loops=1)
Sort Key: compress_hyper_6_35_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
Sort Method: quicksort
-> Seq Scan on compress_hyper_6_35_chunk (actual rows=4 loops=1)
Filter: (device_id = 2)
Rows Removed by Filter: 8
-> Custom Scan (DecompressChunk) on _hyper_5_23_chunk o2_2 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_23_chunk o2_2 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_32_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_32_chunk (never executed)
Sort Key: compress_hyper_6_32_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
-> Seq Scan on compress_hyper_6_32_chunk (never executed)
Filter: (device_id = 2)
-> Custom Scan (DecompressChunk) on _hyper_5_26_chunk o2_3 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_26_chunk o2_3 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_29_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_29_chunk (never executed)
Sort Key: compress_hyper_6_29_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
-> Seq Scan on compress_hyper_6_29_chunk (never executed) (26 rows)
Filter: (device_id = 2)
(41 rows)
-- test RIGHT JOIN on time column -- test RIGHT JOIN on time column
-- should use 2 ChunkAppend -- should use 2 ChunkAppend
@ -3546,50 +3511,35 @@ WHERE o1.device_id = 1
AND o2.device_id = 2 AND o2.device_id = 2
ORDER BY o2.time ORDER BY o2.time
LIMIT 100; LIMIT 100;
QUERY PLAN QUERY PLAN
----------------------------------------------------------------------------------------------------------- ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
Limit (actual rows=100 loops=1) Limit (actual rows=100 loops=1)
-> Merge Join (actual rows=100 loops=1) -> Merge Join (actual rows=100 loops=1)
Merge Cond: (o1."time" = o2."time") Merge Cond: (o1."time" = o2."time")
-> Custom Scan (ChunkAppend) on metrics_space_compressed o1 (actual rows=100 loops=1) -> Custom Scan (ChunkAppend) on metrics_space_compressed o1 (actual rows=100 loops=1)
Order: o1."time" Order: o1."time"
-> Custom Scan (DecompressChunk) on _hyper_5_19_chunk o1_1 (actual rows=100 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_19_chunk o1_1 (actual rows=100 loops=1)
-> Sort (actual rows=1 loops=1) -> Index Scan Backward using compress_hyper_6_36_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_36_chunk (actual rows=1 loops=1)
Sort Key: compress_hyper_6_36_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
Sort Method: quicksort
-> Seq Scan on compress_hyper_6_36_chunk (actual rows=4 loops=1)
Filter: (device_id = 1)
-> Custom Scan (DecompressChunk) on _hyper_5_22_chunk o1_2 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_22_chunk o1_2 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_33_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_33_chunk (never executed)
Sort Key: compress_hyper_6_33_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
-> Seq Scan on compress_hyper_6_33_chunk (never executed)
Filter: (device_id = 1)
-> Custom Scan (DecompressChunk) on _hyper_5_25_chunk o1_3 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_25_chunk o1_3 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_30_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_30_chunk (never executed)
Sort Key: compress_hyper_6_30_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
-> Seq Scan on compress_hyper_6_30_chunk (never executed)
Filter: (device_id = 1)
-> Materialize (actual rows=100 loops=1) -> Materialize (actual rows=100 loops=1)
-> Custom Scan (ChunkAppend) on metrics_space_compressed o2 (actual rows=100 loops=1) -> Custom Scan (ChunkAppend) on metrics_space_compressed o2 (actual rows=100 loops=1)
Order: o2."time" Order: o2."time"
-> Custom Scan (DecompressChunk) on _hyper_5_20_chunk o2_1 (actual rows=100 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_20_chunk o2_1 (actual rows=100 loops=1)
-> Sort (actual rows=1 loops=1) -> Index Scan Backward using compress_hyper_6_35_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_35_chunk (actual rows=1 loops=1)
Sort Key: compress_hyper_6_35_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
Sort Method: quicksort
-> Seq Scan on compress_hyper_6_35_chunk (actual rows=4 loops=1)
Filter: (device_id = 2)
Rows Removed by Filter: 8
-> Custom Scan (DecompressChunk) on _hyper_5_23_chunk o2_2 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_23_chunk o2_2 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_32_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_32_chunk (never executed)
Sort Key: compress_hyper_6_32_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
-> Seq Scan on compress_hyper_6_32_chunk (never executed)
Filter: (device_id = 2)
-> Custom Scan (DecompressChunk) on _hyper_5_26_chunk o2_3 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_26_chunk o2_3 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_29_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_29_chunk (never executed)
Sort Key: compress_hyper_6_29_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
-> Seq Scan on compress_hyper_6_29_chunk (never executed) (26 rows)
Filter: (device_id = 2)
(41 rows)
-- test JOIN on time column with ON clause expression order switched -- test JOIN on time column with ON clause expression order switched
-- should use 2 ChunkAppend -- should use 2 ChunkAppend
@ -3601,50 +3551,35 @@ WHERE o1.device_id = 1
AND o2.device_id = 2 AND o2.device_id = 2
ORDER BY o1.time ORDER BY o1.time
LIMIT 100; LIMIT 100;
QUERY PLAN QUERY PLAN
----------------------------------------------------------------------------------------------------------- ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
Limit (actual rows=100 loops=1) Limit (actual rows=100 loops=1)
-> Merge Join (actual rows=100 loops=1) -> Merge Join (actual rows=100 loops=1)
Merge Cond: (o1."time" = o2."time") Merge Cond: (o1."time" = o2."time")
-> Custom Scan (ChunkAppend) on metrics_space_compressed o1 (actual rows=100 loops=1) -> Custom Scan (ChunkAppend) on metrics_space_compressed o1 (actual rows=100 loops=1)
Order: o1."time" Order: o1."time"
-> Custom Scan (DecompressChunk) on _hyper_5_19_chunk o1_1 (actual rows=100 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_19_chunk o1_1 (actual rows=100 loops=1)
-> Sort (actual rows=1 loops=1) -> Index Scan Backward using compress_hyper_6_36_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_36_chunk (actual rows=1 loops=1)
Sort Key: compress_hyper_6_36_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
Sort Method: quicksort
-> Seq Scan on compress_hyper_6_36_chunk (actual rows=4 loops=1)
Filter: (device_id = 1)
-> Custom Scan (DecompressChunk) on _hyper_5_22_chunk o1_2 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_22_chunk o1_2 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_33_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_33_chunk (never executed)
Sort Key: compress_hyper_6_33_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
-> Seq Scan on compress_hyper_6_33_chunk (never executed)
Filter: (device_id = 1)
-> Custom Scan (DecompressChunk) on _hyper_5_25_chunk o1_3 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_25_chunk o1_3 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_30_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_30_chunk (never executed)
Sort Key: compress_hyper_6_30_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
-> Seq Scan on compress_hyper_6_30_chunk (never executed)
Filter: (device_id = 1)
-> Materialize (actual rows=100 loops=1) -> Materialize (actual rows=100 loops=1)
-> Custom Scan (ChunkAppend) on metrics_space_compressed o2 (actual rows=100 loops=1) -> Custom Scan (ChunkAppend) on metrics_space_compressed o2 (actual rows=100 loops=1)
Order: o2."time" Order: o2."time"
-> Custom Scan (DecompressChunk) on _hyper_5_20_chunk o2_1 (actual rows=100 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_20_chunk o2_1 (actual rows=100 loops=1)
-> Sort (actual rows=1 loops=1) -> Index Scan Backward using compress_hyper_6_35_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_35_chunk (actual rows=1 loops=1)
Sort Key: compress_hyper_6_35_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
Sort Method: quicksort
-> Seq Scan on compress_hyper_6_35_chunk (actual rows=4 loops=1)
Filter: (device_id = 2)
Rows Removed by Filter: 8
-> Custom Scan (DecompressChunk) on _hyper_5_23_chunk o2_2 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_23_chunk o2_2 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_32_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_32_chunk (never executed)
Sort Key: compress_hyper_6_32_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
-> Seq Scan on compress_hyper_6_32_chunk (never executed)
Filter: (device_id = 2)
-> Custom Scan (DecompressChunk) on _hyper_5_26_chunk o2_3 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_26_chunk o2_3 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_29_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_29_chunk (never executed)
Sort Key: compress_hyper_6_29_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
-> Seq Scan on compress_hyper_6_29_chunk (never executed) (26 rows)
Filter: (device_id = 2)
(41 rows)
-- test JOIN on time column with equality condition in WHERE clause -- test JOIN on time column with equality condition in WHERE clause
-- should use 2 ChunkAppend -- should use 2 ChunkAppend
@ -3657,50 +3592,35 @@ WHERE o1.time = o2.time
AND o2.device_id = 2 AND o2.device_id = 2
ORDER BY o1.time ORDER BY o1.time
LIMIT 100; LIMIT 100;
QUERY PLAN QUERY PLAN
----------------------------------------------------------------------------------------------------------- ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
Limit (actual rows=100 loops=1) Limit (actual rows=100 loops=1)
-> Merge Join (actual rows=100 loops=1) -> Merge Join (actual rows=100 loops=1)
Merge Cond: (o1."time" = o2."time") Merge Cond: (o1."time" = o2."time")
-> Custom Scan (ChunkAppend) on metrics_space_compressed o1 (actual rows=100 loops=1) -> Custom Scan (ChunkAppend) on metrics_space_compressed o1 (actual rows=100 loops=1)
Order: o1."time" Order: o1."time"
-> Custom Scan (DecompressChunk) on _hyper_5_19_chunk o1_1 (actual rows=100 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_19_chunk o1_1 (actual rows=100 loops=1)
-> Sort (actual rows=1 loops=1) -> Index Scan Backward using compress_hyper_6_36_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_36_chunk (actual rows=1 loops=1)
Sort Key: compress_hyper_6_36_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
Sort Method: quicksort
-> Seq Scan on compress_hyper_6_36_chunk (actual rows=4 loops=1)
Filter: (device_id = 1)
-> Custom Scan (DecompressChunk) on _hyper_5_22_chunk o1_2 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_22_chunk o1_2 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_33_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_33_chunk (never executed)
Sort Key: compress_hyper_6_33_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
-> Seq Scan on compress_hyper_6_33_chunk (never executed)
Filter: (device_id = 1)
-> Custom Scan (DecompressChunk) on _hyper_5_25_chunk o1_3 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_25_chunk o1_3 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_30_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_30_chunk (never executed)
Sort Key: compress_hyper_6_30_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
-> Seq Scan on compress_hyper_6_30_chunk (never executed)
Filter: (device_id = 1)
-> Materialize (actual rows=100 loops=1) -> Materialize (actual rows=100 loops=1)
-> Custom Scan (ChunkAppend) on metrics_space_compressed o2 (actual rows=100 loops=1) -> Custom Scan (ChunkAppend) on metrics_space_compressed o2 (actual rows=100 loops=1)
Order: o2."time" Order: o2."time"
-> Custom Scan (DecompressChunk) on _hyper_5_20_chunk o2_1 (actual rows=100 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_20_chunk o2_1 (actual rows=100 loops=1)
-> Sort (actual rows=1 loops=1) -> Index Scan Backward using compress_hyper_6_35_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_35_chunk (actual rows=1 loops=1)
Sort Key: compress_hyper_6_35_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
Sort Method: quicksort
-> Seq Scan on compress_hyper_6_35_chunk (actual rows=4 loops=1)
Filter: (device_id = 2)
Rows Removed by Filter: 8
-> Custom Scan (DecompressChunk) on _hyper_5_23_chunk o2_2 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_23_chunk o2_2 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_32_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_32_chunk (never executed)
Sort Key: compress_hyper_6_32_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
-> Seq Scan on compress_hyper_6_32_chunk (never executed)
Filter: (device_id = 2)
-> Custom Scan (DecompressChunk) on _hyper_5_26_chunk o2_3 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_26_chunk o2_3 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_29_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_29_chunk (never executed)
Sort Key: compress_hyper_6_29_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
-> Seq Scan on compress_hyper_6_29_chunk (never executed) (26 rows)
Filter: (device_id = 2)
(41 rows)
-- test JOIN on time column with ORDER BY 2nd hypertable -- test JOIN on time column with ORDER BY 2nd hypertable
-- should use 2 ChunkAppend -- should use 2 ChunkAppend
@ -3712,50 +3632,35 @@ WHERE o1.device_id = 1
AND o2.device_id = 2 AND o2.device_id = 2
ORDER BY o2.time ORDER BY o2.time
LIMIT 100; LIMIT 100;
QUERY PLAN QUERY PLAN
----------------------------------------------------------------------------------------------------------- ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
Limit (actual rows=100 loops=1) Limit (actual rows=100 loops=1)
-> Merge Join (actual rows=100 loops=1) -> Merge Join (actual rows=100 loops=1)
Merge Cond: (o1."time" = o2."time") Merge Cond: (o1."time" = o2."time")
-> Custom Scan (ChunkAppend) on metrics_space_compressed o1 (actual rows=100 loops=1) -> Custom Scan (ChunkAppend) on metrics_space_compressed o1 (actual rows=100 loops=1)
Order: o1."time" Order: o1."time"
-> Custom Scan (DecompressChunk) on _hyper_5_19_chunk o1_1 (actual rows=100 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_19_chunk o1_1 (actual rows=100 loops=1)
-> Sort (actual rows=1 loops=1) -> Index Scan Backward using compress_hyper_6_36_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_36_chunk (actual rows=1 loops=1)
Sort Key: compress_hyper_6_36_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
Sort Method: quicksort
-> Seq Scan on compress_hyper_6_36_chunk (actual rows=4 loops=1)
Filter: (device_id = 1)
-> Custom Scan (DecompressChunk) on _hyper_5_22_chunk o1_2 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_22_chunk o1_2 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_33_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_33_chunk (never executed)
Sort Key: compress_hyper_6_33_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
-> Seq Scan on compress_hyper_6_33_chunk (never executed)
Filter: (device_id = 1)
-> Custom Scan (DecompressChunk) on _hyper_5_25_chunk o1_3 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_25_chunk o1_3 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_30_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_30_chunk (never executed)
Sort Key: compress_hyper_6_30_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
-> Seq Scan on compress_hyper_6_30_chunk (never executed)
Filter: (device_id = 1)
-> Materialize (actual rows=100 loops=1) -> Materialize (actual rows=100 loops=1)
-> Custom Scan (ChunkAppend) on metrics_space_compressed o2 (actual rows=100 loops=1) -> Custom Scan (ChunkAppend) on metrics_space_compressed o2 (actual rows=100 loops=1)
Order: o2."time" Order: o2."time"
-> Custom Scan (DecompressChunk) on _hyper_5_20_chunk o2_1 (actual rows=100 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_20_chunk o2_1 (actual rows=100 loops=1)
-> Sort (actual rows=1 loops=1) -> Index Scan Backward using compress_hyper_6_35_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_35_chunk (actual rows=1 loops=1)
Sort Key: compress_hyper_6_35_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
Sort Method: quicksort
-> Seq Scan on compress_hyper_6_35_chunk (actual rows=4 loops=1)
Filter: (device_id = 2)
Rows Removed by Filter: 8
-> Custom Scan (DecompressChunk) on _hyper_5_23_chunk o2_2 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_23_chunk o2_2 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_32_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_32_chunk (never executed)
Sort Key: compress_hyper_6_32_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
-> Seq Scan on compress_hyper_6_32_chunk (never executed)
Filter: (device_id = 2)
-> Custom Scan (DecompressChunk) on _hyper_5_26_chunk o2_3 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_26_chunk o2_3 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_29_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_29_chunk (never executed)
Sort Key: compress_hyper_6_29_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
-> Seq Scan on compress_hyper_6_29_chunk (never executed) (26 rows)
Filter: (device_id = 2)
(41 rows)
-- test JOIN on time column and device_id -- test JOIN on time column and device_id
-- should use 2 ChunkAppend -- should use 2 ChunkAppend
@ -3766,8 +3671,8 @@ FROM :TEST_TABLE o1
AND o1.time = o2.time AND o1.time = o2.time
ORDER BY o1.time ORDER BY o1.time
LIMIT 100; LIMIT 100;
QUERY PLAN QUERY PLAN
-------------------------------------------------------------------------------------------------------------------------- --------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
Limit (actual rows=100 loops=1) Limit (actual rows=100 loops=1)
-> Merge Join (actual rows=100 loops=1) -> Merge Join (actual rows=100 loops=1)
Merge Cond: ((o1."time" = o2."time") AND (o1.device_id = o2.device_id)) Merge Cond: ((o1."time" = o2."time") AND (o1.device_id = o2.device_id))
@ -3776,45 +3681,45 @@ FROM :TEST_TABLE o1
Sort Method: quicksort Sort Method: quicksort
-> Append (actual rows=68370 loops=1) -> Append (actual rows=68370 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_5_19_chunk o1 (actual rows=3598 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_19_chunk o1 (actual rows=3598 loops=1)
-> Seq Scan on compress_hyper_6_36_chunk (actual rows=4 loops=1) -> Index Scan using compress_hyper_6_36_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_36_chunk (actual rows=4 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_5_20_chunk o1_1 (actual rows=10794 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_20_chunk o1_1 (actual rows=10794 loops=1)
-> Seq Scan on compress_hyper_6_35_chunk (actual rows=12 loops=1) -> Index Scan using compress_hyper_6_35_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_35_chunk (actual rows=12 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_5_21_chunk o1_2 (actual rows=3598 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_21_chunk o1_2 (actual rows=3598 loops=1)
-> Seq Scan on compress_hyper_6_34_chunk (actual rows=4 loops=1) -> Index Scan using compress_hyper_6_34_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_34_chunk (actual rows=4 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_5_22_chunk o1_3 (actual rows=5038 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_22_chunk o1_3 (actual rows=5038 loops=1)
-> Seq Scan on compress_hyper_6_33_chunk (actual rows=6 loops=1) -> Index Scan using compress_hyper_6_33_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_33_chunk (actual rows=6 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_5_23_chunk o1_4 (actual rows=15114 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_23_chunk o1_4 (actual rows=15114 loops=1)
-> Seq Scan on compress_hyper_6_32_chunk (actual rows=18 loops=1) -> Index Scan using compress_hyper_6_32_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_32_chunk (actual rows=18 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_5_24_chunk o1_5 (actual rows=5038 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_24_chunk o1_5 (actual rows=5038 loops=1)
-> Seq Scan on compress_hyper_6_31_chunk (actual rows=6 loops=1) -> Index Scan using compress_hyper_6_31_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_31_chunk (actual rows=6 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_5_25_chunk o1_6 (actual rows=5038 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_25_chunk o1_6 (actual rows=5038 loops=1)
-> Seq Scan on compress_hyper_6_30_chunk (actual rows=6 loops=1) -> Index Scan using compress_hyper_6_30_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_30_chunk (actual rows=6 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_5_26_chunk o1_7 (actual rows=15114 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_26_chunk o1_7 (actual rows=15114 loops=1)
-> Seq Scan on compress_hyper_6_29_chunk (actual rows=18 loops=1) -> Index Scan using compress_hyper_6_29_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_29_chunk (actual rows=18 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_5_27_chunk o1_8 (actual rows=5038 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_27_chunk o1_8 (actual rows=5038 loops=1)
-> Seq Scan on compress_hyper_6_28_chunk (actual rows=6 loops=1) -> Index Scan using compress_hyper_6_28_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_28_chunk (actual rows=6 loops=1)
-> Sort (actual rows=100 loops=1) -> Sort (actual rows=100 loops=1)
Sort Key: o2."time", o2.device_id Sort Key: o2."time", o2.device_id
Sort Method: quicksort Sort Method: quicksort
-> Append (actual rows=68370 loops=1) -> Append (actual rows=68370 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_5_19_chunk o2 (actual rows=3598 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_19_chunk o2 (actual rows=3598 loops=1)
-> Seq Scan on compress_hyper_6_36_chunk compress_hyper_6_36_chunk_1 (actual rows=4 loops=1) -> Index Scan using compress_hyper_6_36_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_36_chunk compress_hyper_6_36_chunk_1 (actual rows=4 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_5_20_chunk o2_1 (actual rows=10794 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_20_chunk o2_1 (actual rows=10794 loops=1)
-> Seq Scan on compress_hyper_6_35_chunk compress_hyper_6_35_chunk_1 (actual rows=12 loops=1) -> Index Scan using compress_hyper_6_35_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_35_chunk compress_hyper_6_35_chunk_1 (actual rows=12 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_5_21_chunk o2_2 (actual rows=3598 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_21_chunk o2_2 (actual rows=3598 loops=1)
-> Seq Scan on compress_hyper_6_34_chunk compress_hyper_6_34_chunk_1 (actual rows=4 loops=1) -> Index Scan using compress_hyper_6_34_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_34_chunk compress_hyper_6_34_chunk_1 (actual rows=4 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_5_22_chunk o2_3 (actual rows=5038 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_22_chunk o2_3 (actual rows=5038 loops=1)
-> Seq Scan on compress_hyper_6_33_chunk compress_hyper_6_33_chunk_1 (actual rows=6 loops=1) -> Index Scan using compress_hyper_6_33_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_33_chunk compress_hyper_6_33_chunk_1 (actual rows=6 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_5_23_chunk o2_4 (actual rows=15114 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_23_chunk o2_4 (actual rows=15114 loops=1)
-> Seq Scan on compress_hyper_6_32_chunk compress_hyper_6_32_chunk_1 (actual rows=18 loops=1) -> Index Scan using compress_hyper_6_32_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_32_chunk compress_hyper_6_32_chunk_1 (actual rows=18 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_5_24_chunk o2_5 (actual rows=5038 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_24_chunk o2_5 (actual rows=5038 loops=1)
-> Seq Scan on compress_hyper_6_31_chunk compress_hyper_6_31_chunk_1 (actual rows=6 loops=1) -> Index Scan using compress_hyper_6_31_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_31_chunk compress_hyper_6_31_chunk_1 (actual rows=6 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_5_25_chunk o2_6 (actual rows=5038 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_25_chunk o2_6 (actual rows=5038 loops=1)
-> Seq Scan on compress_hyper_6_30_chunk compress_hyper_6_30_chunk_1 (actual rows=6 loops=1) -> Index Scan using compress_hyper_6_30_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_30_chunk compress_hyper_6_30_chunk_1 (actual rows=6 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_5_26_chunk o2_7 (actual rows=15114 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_26_chunk o2_7 (actual rows=15114 loops=1)
-> Seq Scan on compress_hyper_6_29_chunk compress_hyper_6_29_chunk_1 (actual rows=18 loops=1) -> Index Scan using compress_hyper_6_29_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_29_chunk compress_hyper_6_29_chunk_1 (actual rows=18 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_5_27_chunk o2_8 (actual rows=5038 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_27_chunk o2_8 (actual rows=5038 loops=1)
-> Seq Scan on compress_hyper_6_28_chunk compress_hyper_6_28_chunk_1 (actual rows=6 loops=1) -> Index Scan using compress_hyper_6_28_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_28_chunk compress_hyper_6_28_chunk_1 (actual rows=6 loops=1)
(47 rows) (47 rows)
-- test JOIN on device_id -- test JOIN on device_id
@ -3826,40 +3731,33 @@ FROM :TEST_TABLE o1
WHERE o1.device_id = 1 WHERE o1.device_id = 1
ORDER BY o1.time ORDER BY o1.time
LIMIT 100; LIMIT 100;
QUERY PLAN QUERY PLAN
------------------------------------------------------------------------------------------------------------------------- -------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
Limit (actual rows=100 loops=1) Limit (actual rows=100 loops=1)
-> Nested Loop (actual rows=100 loops=1) -> Nested Loop (actual rows=100 loops=1)
-> Custom Scan (ChunkAppend) on metrics_space_compressed o1 (actual rows=1 loops=1) -> Custom Scan (ChunkAppend) on metrics_space_compressed o1 (actual rows=1 loops=1)
Order: o1."time" Order: o1."time"
-> Custom Scan (DecompressChunk) on _hyper_5_19_chunk o1_1 (actual rows=1 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_19_chunk o1_1 (actual rows=1 loops=1)
-> Sort (actual rows=1 loops=1) -> Index Scan Backward using compress_hyper_6_36_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_36_chunk (actual rows=1 loops=1)
Sort Key: compress_hyper_6_36_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
Sort Method: quicksort
-> Seq Scan on compress_hyper_6_36_chunk (actual rows=4 loops=1)
Filter: (device_id = 1)
-> Custom Scan (DecompressChunk) on _hyper_5_22_chunk o1_2 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_22_chunk o1_2 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_33_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_33_chunk (never executed)
Sort Key: compress_hyper_6_33_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
-> Seq Scan on compress_hyper_6_33_chunk (never executed)
Filter: (device_id = 1)
-> Custom Scan (DecompressChunk) on _hyper_5_25_chunk o1_3 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_25_chunk o1_3 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_30_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_30_chunk (never executed)
Sort Key: compress_hyper_6_30_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
-> Seq Scan on compress_hyper_6_30_chunk (never executed)
Filter: (device_id = 1)
-> Materialize (actual rows=100 loops=1) -> Materialize (actual rows=100 loops=1)
-> Append (actual rows=100 loops=1) -> Append (actual rows=100 loops=1)
-> Custom Scan (DecompressChunk) on _hyper_5_25_chunk o2 (actual rows=100 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_25_chunk o2 (actual rows=100 loops=1)
-> Seq Scan on compress_hyper_6_30_chunk compress_hyper_6_30_chunk_1 (actual rows=1 loops=1) -> Index Scan using compress_hyper_6_30_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_30_chunk compress_hyper_6_30_chunk_1 (actual rows=1 loops=1)
Filter: (device_id = 1) Index Cond: (device_id = 1)
-> Custom Scan (DecompressChunk) on _hyper_5_19_chunk o2_1 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_19_chunk o2_1 (never executed)
-> Seq Scan on compress_hyper_6_36_chunk compress_hyper_6_36_chunk_1 (never executed) -> Index Scan using compress_hyper_6_36_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_36_chunk compress_hyper_6_36_chunk_1 (never executed)
Filter: (device_id = 1) Index Cond: (device_id = 1)
-> Custom Scan (DecompressChunk) on _hyper_5_22_chunk o2_2 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_22_chunk o2_2 (never executed)
-> Seq Scan on compress_hyper_6_33_chunk compress_hyper_6_33_chunk_1 (never executed) -> Index Scan using compress_hyper_6_33_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_33_chunk compress_hyper_6_33_chunk_1 (never executed)
Filter: (device_id = 1) Index Cond: (device_id = 1)
(31 rows) (24 rows)
-- test JOIN on time column with implicit join -- test JOIN on time column with implicit join
-- should use 2 ChunkAppend -- should use 2 ChunkAppend
@ -3872,50 +3770,35 @@ WHERE o1.time = o2.time
AND o2.device_id = 2 AND o2.device_id = 2
ORDER BY o1.time ORDER BY o1.time
LIMIT 100; LIMIT 100;
QUERY PLAN QUERY PLAN
----------------------------------------------------------------------------------------------------------- ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
Limit (actual rows=100 loops=1) Limit (actual rows=100 loops=1)
-> Merge Join (actual rows=100 loops=1) -> Merge Join (actual rows=100 loops=1)
Merge Cond: (o1."time" = o2."time") Merge Cond: (o1."time" = o2."time")
-> Custom Scan (ChunkAppend) on metrics_space_compressed o1 (actual rows=100 loops=1) -> Custom Scan (ChunkAppend) on metrics_space_compressed o1 (actual rows=100 loops=1)
Order: o1."time" Order: o1."time"
-> Custom Scan (DecompressChunk) on _hyper_5_19_chunk o1_1 (actual rows=100 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_19_chunk o1_1 (actual rows=100 loops=1)
-> Sort (actual rows=1 loops=1) -> Index Scan Backward using compress_hyper_6_36_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_36_chunk (actual rows=1 loops=1)
Sort Key: compress_hyper_6_36_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
Sort Method: quicksort
-> Seq Scan on compress_hyper_6_36_chunk (actual rows=4 loops=1)
Filter: (device_id = 1)
-> Custom Scan (DecompressChunk) on _hyper_5_22_chunk o1_2 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_22_chunk o1_2 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_33_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_33_chunk (never executed)
Sort Key: compress_hyper_6_33_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
-> Seq Scan on compress_hyper_6_33_chunk (never executed)
Filter: (device_id = 1)
-> Custom Scan (DecompressChunk) on _hyper_5_25_chunk o1_3 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_25_chunk o1_3 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_30_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_30_chunk (never executed)
Sort Key: compress_hyper_6_30_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
-> Seq Scan on compress_hyper_6_30_chunk (never executed)
Filter: (device_id = 1)
-> Materialize (actual rows=100 loops=1) -> Materialize (actual rows=100 loops=1)
-> Custom Scan (ChunkAppend) on metrics_space_compressed o2 (actual rows=100 loops=1) -> Custom Scan (ChunkAppend) on metrics_space_compressed o2 (actual rows=100 loops=1)
Order: o2."time" Order: o2."time"
-> Custom Scan (DecompressChunk) on _hyper_5_20_chunk o2_1 (actual rows=100 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_20_chunk o2_1 (actual rows=100 loops=1)
-> Sort (actual rows=1 loops=1) -> Index Scan Backward using compress_hyper_6_35_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_35_chunk (actual rows=1 loops=1)
Sort Key: compress_hyper_6_35_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
Sort Method: quicksort
-> Seq Scan on compress_hyper_6_35_chunk (actual rows=4 loops=1)
Filter: (device_id = 2)
Rows Removed by Filter: 8
-> Custom Scan (DecompressChunk) on _hyper_5_23_chunk o2_2 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_23_chunk o2_2 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_32_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_32_chunk (never executed)
Sort Key: compress_hyper_6_32_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
-> Seq Scan on compress_hyper_6_32_chunk (never executed)
Filter: (device_id = 2)
-> Custom Scan (DecompressChunk) on _hyper_5_26_chunk o2_3 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_26_chunk o2_3 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_29_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_29_chunk (never executed)
Sort Key: compress_hyper_6_29_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
-> Seq Scan on compress_hyper_6_29_chunk (never executed) (26 rows)
Filter: (device_id = 2)
(41 rows)
-- test JOIN on time column with 3 hypertables -- test JOIN on time column with 3 hypertables
-- should use 3 ChunkAppend -- should use 3 ChunkAppend
@ -3929,72 +3812,51 @@ WHERE o1.device_id = 1
AND o3.device_id = 3 AND o3.device_id = 3
ORDER BY o1.time ORDER BY o1.time
LIMIT 100; LIMIT 100;
QUERY PLAN QUERY PLAN
----------------------------------------------------------------------------------------------------------------------- ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
Limit (actual rows=100 loops=1) Limit (actual rows=100 loops=1)
-> Merge Join (actual rows=100 loops=1) -> Merge Join (actual rows=100 loops=1)
Merge Cond: (o3."time" = o1."time") Merge Cond: (o3."time" = o1."time")
-> Custom Scan (ChunkAppend) on metrics_space_compressed o3 (actual rows=100 loops=1) -> Custom Scan (ChunkAppend) on metrics_space_compressed o3 (actual rows=100 loops=1)
Order: o3."time" Order: o3."time"
-> Custom Scan (DecompressChunk) on _hyper_5_21_chunk o3_1 (actual rows=100 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_21_chunk o3_1 (actual rows=100 loops=1)
-> Sort (actual rows=1 loops=1) -> Index Scan Backward using compress_hyper_6_34_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_34_chunk (actual rows=1 loops=1)
Sort Key: compress_hyper_6_34_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 3)
Sort Method: quicksort
-> Seq Scan on compress_hyper_6_34_chunk (actual rows=4 loops=1)
Filter: (device_id = 3)
-> Custom Scan (DecompressChunk) on _hyper_5_24_chunk o3_2 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_24_chunk o3_2 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_31_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_31_chunk (never executed)
Sort Key: compress_hyper_6_31_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 3)
-> Seq Scan on compress_hyper_6_31_chunk (never executed)
Filter: (device_id = 3)
-> Custom Scan (DecompressChunk) on _hyper_5_27_chunk o3_3 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_27_chunk o3_3 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_28_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_28_chunk (never executed)
Sort Key: compress_hyper_6_28_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 3)
-> Seq Scan on compress_hyper_6_28_chunk (never executed)
Filter: (device_id = 3)
-> Materialize (actual rows=100 loops=1) -> Materialize (actual rows=100 loops=1)
-> Merge Join (actual rows=100 loops=1) -> Merge Join (actual rows=100 loops=1)
Merge Cond: (o1."time" = o2."time") Merge Cond: (o1."time" = o2."time")
-> Custom Scan (ChunkAppend) on metrics_space_compressed o1 (actual rows=100 loops=1) -> Custom Scan (ChunkAppend) on metrics_space_compressed o1 (actual rows=100 loops=1)
Order: o1."time" Order: o1."time"
-> Custom Scan (DecompressChunk) on _hyper_5_19_chunk o1_1 (actual rows=100 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_19_chunk o1_1 (actual rows=100 loops=1)
-> Sort (actual rows=1 loops=1) -> Index Scan Backward using compress_hyper_6_36_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_36_chunk (actual rows=1 loops=1)
Sort Key: compress_hyper_6_36_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
Sort Method: quicksort
-> Seq Scan on compress_hyper_6_36_chunk (actual rows=4 loops=1)
Filter: (device_id = 1)
-> Custom Scan (DecompressChunk) on _hyper_5_22_chunk o1_2 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_22_chunk o1_2 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_33_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_33_chunk (never executed)
Sort Key: compress_hyper_6_33_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
-> Seq Scan on compress_hyper_6_33_chunk (never executed)
Filter: (device_id = 1)
-> Custom Scan (DecompressChunk) on _hyper_5_25_chunk o1_3 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_25_chunk o1_3 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_30_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_30_chunk (never executed)
Sort Key: compress_hyper_6_30_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 1)
-> Seq Scan on compress_hyper_6_30_chunk (never executed)
Filter: (device_id = 1)
-> Materialize (actual rows=100 loops=1) -> Materialize (actual rows=100 loops=1)
-> Custom Scan (ChunkAppend) on metrics_space_compressed o2 (actual rows=100 loops=1) -> Custom Scan (ChunkAppend) on metrics_space_compressed o2 (actual rows=100 loops=1)
Order: o2."time" Order: o2."time"
-> Custom Scan (DecompressChunk) on _hyper_5_20_chunk o2_1 (actual rows=100 loops=1) -> Custom Scan (DecompressChunk) on _hyper_5_20_chunk o2_1 (actual rows=100 loops=1)
-> Sort (actual rows=1 loops=1) -> Index Scan Backward using compress_hyper_6_35_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_35_chunk (actual rows=1 loops=1)
Sort Key: compress_hyper_6_35_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
Sort Method: quicksort
-> Seq Scan on compress_hyper_6_35_chunk (actual rows=4 loops=1)
Filter: (device_id = 2)
Rows Removed by Filter: 8
-> Custom Scan (DecompressChunk) on _hyper_5_23_chunk o2_2 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_23_chunk o2_2 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_32_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_32_chunk (never executed)
Sort Key: compress_hyper_6_32_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
-> Seq Scan on compress_hyper_6_32_chunk (never executed)
Filter: (device_id = 2)
-> Custom Scan (DecompressChunk) on _hyper_5_26_chunk o2_3 (never executed) -> Custom Scan (DecompressChunk) on _hyper_5_26_chunk o2_3 (never executed)
-> Sort (never executed) -> Index Scan Backward using compress_hyper_6_29_chunk__compressed_hypertable_6_device_id__t on compress_hyper_6_29_chunk (never executed)
Sort Key: compress_hyper_6_29_chunk._ts_meta_sequence_num DESC Index Cond: (device_id = 2)
-> Seq Scan on compress_hyper_6_29_chunk (never executed) (40 rows)
Filter: (device_id = 2)
(62 rows)
RESET enable_seqscan;
-- get results for all the queries -- get results for all the queries
-- run queries on uncompressed hypertable and store result -- run queries on uncompressed hypertable and store result
\set PREFIX '' \set PREFIX ''

4
tsl/test/shared/sql/include/constraint_exclusion_prepared.sql
View File

@ -37,6 +37,8 @@ LIMIT 100;
DEALLOCATE prep; DEALLOCATE prep;
-- runtime exclusion with LATERAL and 2 hypertables -- runtime exclusion with LATERAL and 2 hypertables
SET enable_seqscan TO false;
PREPARE prep AS PREPARE prep AS
SELECT m1.time, SELECT m1.time,
m2.time m2.time
@ -57,6 +59,8 @@ LIMIT 100;
:PREFIX EXECUTE prep; :PREFIX EXECUTE prep;
DEALLOCATE prep; DEALLOCATE prep;
RESET enable_seqscan;
-- executor startup exclusion with subquery -- executor startup exclusion with subquery
PREPARE prep AS PREPARE prep AS
SELECT time SELECT time

2
tsl/test/shared/sql/include/ordered_append.sql
View File

@ -72,6 +72,7 @@ LIMIT 1;
-- test equality constraint on ORDER BY prefix -- test equality constraint on ORDER BY prefix
-- currently not optimized -- currently not optimized
SET enable_seqscan TO false;
:PREFIX :PREFIX
SELECT time, SELECT time,
device_id device_id
@ -80,6 +81,7 @@ WHERE device_id = 1
ORDER BY device_id, ORDER BY device_id,
time time
LIMIT 10; LIMIT 10;
RESET enable_seqscan;
-- queries without LIMIT should use ordered append -- queries without LIMIT should use ordered append
:PREFIX :PREFIX

4
tsl/test/shared/sql/include/ordered_append_join.sql
View File

@ -145,6 +145,8 @@ ORDER BY time;
RESET enable_hashjoin; RESET enable_hashjoin;
SET enable_seqscan TO false;
-- test JOIN on time column -- test JOIN on time column
-- should use 2 ChunkAppend -- should use 2 ChunkAppend
:PREFIX :PREFIX
@ -278,3 +280,5 @@ WHERE o1.device_id = 1
AND o3.device_id = 3 AND o3.device_id = 3
ORDER BY o1.time ORDER BY o1.time
LIMIT 100; LIMIT 100;
RESET enable_seqscan;