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

Disable filtration for PartialSortingTransform

Browse Source
This commit is contained in:
Nikolai Kochetov 2020-06-02 11:28:57 +03:00
parent fded020cdc
commit cc3abb12d3
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/Processors/Transforms/PartialSortingTransform.cpp
View File

@ -80,6 +80,7 @@ void PartialSortingTransform::transform(Chunk & chunk)
ColumnRawPtrs block_columns; ColumnRawPtrs block_columns;
UInt64 rows_num = block.rows(); UInt64 rows_num = block.rows();
auto block_limit = limit;
/** If we've saved columns from previously blocks we could filter all rows from current block /** If we've saved columns from previously blocks we could filter all rows from current block
* which are unnecessary for sortBlock(...) because they obviously won't be in the top LIMIT rows. * which are unnecessary for sortBlock(...) because they obviously won't be in the top LIMIT rows.
@ -93,16 +94,19 @@ void PartialSortingTransform::transform(Chunk & chunk)
if (filtered_count == rows_num) if (filtered_count == rows_num)
return; return;
if (filtered_count) if (rows_num - filtered_count < block_limit)
{ {
block_limit = rows_num - filtered_count;
/*
for (auto & column : block.getColumns()) for (auto & column : block.getColumns())
{ {
column = column->filter(filter, rows_num - filtered_count); column = column->filter(filter, rows_num - filtered_count);
} }
*/
} }
} }
sortBlock(block, description, limit); sortBlock(block, description, block_limit);
if (!threshold_block_columns.empty()) if (!threshold_block_columns.empty())
{ {