thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-23 02:00:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge

Browse Source
This commit is contained in:
Michael Kolupaev 2012-11-29 12:26:34 +00:00
parent c2ba1fc202
commit 21ef4655ca
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
dbms/src/Storages/StorageMergeTree.cpp
View File

@ -1318,15 +1318,14 @@ bool StorageMergeTree::selectPartsToMerge(std::vector<DataPartPtr> & parts)
/// Сколько кусков, начиная с текущего, можно включить в валидный отрезок, начинающийся левее текущего куска. /// Сколько кусков, начиная с текущего, можно включить в валидный отрезок, начинающийся левее текущего куска.
/// Нужно для определения максимальности по включению. /// Нужно для определения максимальности по включению.
size_t max_count_from_left = 0; int max_count_from_left = 0;
/// Левый конец отрезка. /// Левый конец отрезка.
for (DataParts::iterator it = data_parts.begin(); it != data_parts.end(); ++it) for (DataParts::iterator it = data_parts.begin(); it != data_parts.end(); ++it)
{ {
const DataPartPtr & first_part = *it; const DataPartPtr & first_part = *it;
if (max_count_from_left > 0) max_count_from_left = std::max(0, max_count_from_left - 1);
--max_count_from_left;
/// Кусок не занят и достаточно мал. /// Кусок не занят и достаточно мал.
if (first_part->currently_merging || if (first_part->currently_merging ||
@ -1390,7 +1389,7 @@ bool StorageMergeTree::selectPartsToMerge(std::vector<DataPartPtr> & parts)
} }
} }
/// Отрезок максимальный по включению валидный отрезок. /// Это максимальный по включению валидный отрезок.
if (cur_longest_len > max_count_from_left) if (cur_longest_len > max_count_from_left)
{ {
max_count_from_left = cur_longest_len; max_count_from_left = cur_longest_len;