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

impl

Browse Source
This commit is contained in:
Nikita Taranov 2024-06-19 16:41:50 +01:00
parent 404f822d6d
commit b125f8166f
2 changed files with 18 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
tests/performance/array_reduce.xml
View File

@ -1,11 +1,8 @@
<test>
<query>SELECT arrayReduce('count', range(100000000))</query>
<query>SELECT arrayReduce('sum', range(100000000))</query>
<query>SELECT arrayReduceInRanges('count', [(1, 100000000)], range(100000000))</query>
<query>SELECT arrayReduceInRanges('sum', [(1, 100000000)], range(100000000))</query>
<query>SELECT arrayReduceInRanges('count', arrayZip(range(1000000), range(1000000)), range(100000000))[123456]</query>
<query>SELECT arrayReduceInRanges('sum', arrayZip(range(1000000), range(1000000)), range(100000000))[123456]</query>
<query>SELECT arrayReduce('count', range(1000000)) FROM numbers_mt(500000000) format Null</query>
<query>SELECT arrayReduce('sum', range(1000000)) FROM numbers_mt(500000000) format Null</query>
<query>SELECT arrayReduceInRanges('count', [(1, 1000000)], range(1000000)) FROM numbers_mt(500000000) format Null</query>
<query>SELECT arrayReduceInRanges('sum', [(1, 1000000)], range(1000000)) FROM numbers_mt(500000000) format Null</query>
<query>SELECT arrayReduceInRanges('count', arrayZip(range(1000000), range(1000000)), range(1000000))[123456]</query>
<query>SELECT arrayReduceInRanges('sum', arrayZip(range(1000000), range(1000000)), range(1000000))[123456]</query>
</test>

14
tests/performance/scripts/perf.py
View File

@ -345,6 +345,18 @@ for query_index in queries_to_run:
print(f"display-name\t{query_index}\t{tsv_escape(query_display_name)}")
for conn_index, c in enumerate(all_connections):
try:
c.execute("SYSTEM JEMALLOC PURGE")
print(
f"purging jemalloc arenas\t{conn_index}\t{c.last_query.elapsed}"
)
except KeyboardInterrupt:
raise
except:
continue
# Prewarm: run once on both servers. Helps to bring the data into memory,
# precompile the queries, etc.
# A query might not run on the old server if it uses a function added in the
@ -427,8 +439,6 @@ for query_index in queries_to_run:
for conn_index, c in enumerate(this_query_connections):
try:
c.execute("SYSTEM JEMALLOC PURGE")
res = c.execute(
q,
query_id=run_id,