thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-25 17:12:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

Automatic style fix

Browse Source
This commit is contained in:
robot-clickhouse 2023-01-03 18:29:09 +00:00
parent da26f62a9b
commit d6c090b530
1 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
tests/integration/test_s3_low_cardinality_right_border/test.py
View File

@ -133,10 +133,15 @@ def test_s3_right_border_2(started_cluster):
res = node1.query("select * from s3_low_cardinality where key = 9000")
assert res == "9000\t9000\n"
def test_s3_right_border_3(started_cluster):
node1.query("drop table if exists s3_low_cardinality")
node1.query("create table s3_low_cardinality (x LowCardinality(String)) engine = MergeTree order by tuple() settings min_bytes_for_wide_part=0, storage_policy = 's3', max_compress_block_size=10000")
node1.query("insert into s3_low_cardinality select toString(number % 8000) || if(number < 8192 * 3, 'aaaaaaaaaaaaaaaa', if(number < 8192 * 6, 'bbbbbbbbbbbbbbbbbbbbbbbb', 'ccccccccccccccccccc')) from numbers(8192 * 9)")
node1.query(
"create table s3_low_cardinality (x LowCardinality(String)) engine = MergeTree order by tuple() settings min_bytes_for_wide_part=0, storage_policy = 's3', max_compress_block_size=10000"
)
node1.query(
"insert into s3_low_cardinality select toString(number % 8000) || if(number < 8192 * 3, 'aaaaaaaaaaaaaaaa', if(number < 8192 * 6, 'bbbbbbbbbbbbbbbbbbbbbbbb', 'ccccccccccccccccccc')) from numbers(8192 * 9)"
)
# Marks are:
# Mark 0, points to 0, 8, has rows after 8192, decompressed size 0.
# Mark 1, points to 0, 8, has rows after 8192, decompressed size 0.
@ -149,7 +154,9 @@ def test_s3_right_border_3(started_cluster):
# Mark 8, points to 84995, 7738, has rows after 8192, decompressed size 0.
# Mark 9, points to 126531, 8637, has rows after 0, decompressed size 0.
res = node1.query("select uniq(x) from s3_low_cardinality settings max_threads=2, merge_tree_min_rows_for_concurrent_read_for_remote_filesystem=1, merge_tree_min_bytes_for_concurrent_read_for_remote_filesystem=1")
res = node1.query(
"select uniq(x) from s3_low_cardinality settings max_threads=2, merge_tree_min_rows_for_concurrent_read_for_remote_filesystem=1, merge_tree_min_bytes_for_concurrent_read_for_remote_filesystem=1"
)
# Reading ranges [0, 5) and [5, 9)
assert res == "23999\n"