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

Update CollapsingSortedAlgorithm.cpp

Browse Source 
Add comment.
This commit is contained in:
Nikolai Kochetov 2021-03-23 11:25:45 +03:00 committed by GitHub
parent d7fc5e69f4
commit ed19864e5b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/Processors/Merges/Algorithms/CollapsingSortedAlgorithm.cpp
View File

@ -162,6 +162,9 @@ IMergingAlgorithm::Status CollapsingSortedAlgorithm::merge()
last_positive_pos = 0;
current_row_sources.resize(0);
/// Here we can return ready chunk.
/// Next iteration, last_row == current_row, and all the counters are zeroed.
/// So, current_row should be correctly processed.
if (res)
return Status(std::move(*res));
}
@ -209,6 +212,8 @@ IMergingAlgorithm::Status CollapsingSortedAlgorithm::merge()
if (auto res = insertRows())
{
/// Queue is empty, and we have inserted all the rows.
/// Set counter to zero so that insertRows() will return immediately next time.
count_positive = 0;
count_negative = 0;
return Status(std::move(*res));