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

Merge pull request #49051 from nickitat/adapt_for_prefetch_read_pool

Browse Source 
Adapt marks count for prefetch read pool
This commit is contained in:
Kseniia Sumarokova 2023-04-23 12:12:47 +02:00 committed by GitHub
commit 7f6488cf37
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
src/Storages/MergeTree/MergeTreePrefetchedReadPool.cpp
View File

@ -297,29 +297,10 @@ MergeTreeReadTaskPtr MergeTreePrefetchedReadPool::getTask(size_t thread)
size_t MergeTreePrefetchedReadPool::getApproxSizeOfGranule(const IMergeTreeDataPart & part) const size_t MergeTreePrefetchedReadPool::getApproxSizeOfGranule(const IMergeTreeDataPart & part) const
{ {
const auto & columns = part.getColumns(); ColumnSize columns_size{};
auto all_columns_are_fixed_size = columns.end() == std::find_if( for (const auto & col_name : column_names)
columns.begin(), columns.end(), columns_size.add(part.getColumnSize(col_name));
[](const auto & col){ return col.type->haveMaximumSizeOfValue() == false; }); return columns_size.data_compressed / part.getMarksCount();
if (all_columns_are_fixed_size)
{
size_t approx_size = 0;
for (const auto & col : columns)
approx_size += col.type->getMaximumSizeOfValueInMemory() * fixed_index_granularity;
if (!index_granularity_bytes)
return approx_size;
return std::min(index_granularity_bytes, approx_size);
}
const size_t approx_size = static_cast<size_t>(std::round(static_cast<double>(part.getBytesOnDisk()) / part.getMarksCount()));
if (!index_granularity_bytes)
return approx_size;
return std::min(index_granularity_bytes, approx_size);
} }
MergeTreePrefetchedReadPool::PartsInfos MergeTreePrefetchedReadPool::getPartsInfos( MergeTreePrefetchedReadPool::PartsInfos MergeTreePrefetchedReadPool::getPartsInfos(