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

Fix test.

Browse Source
This commit is contained in:
Nikolai Kochetov 2019-10-11 21:02:34 +03:00
parent 217eab0cfa
commit 4967bcdbd0
1 changed files with 13 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
dbms/src/Processors/Transforms/FilterTransform.cpp
View File

@ -64,16 +64,7 @@ FilterTransform::FilterTransform(
IProcessor::Status FilterTransform::prepare() IProcessor::Status FilterTransform::prepare()
{ {
bool filter_always_zero = false; if (constant_filter_description.always_false)
if (!initialized)
{
initialized = true;
if (expression->checkColumnIsAlwaysFalse(filter_column_name))
filter_always_zero = true;
}
if (constant_filter_description.always_false || filter_always_zero)
{ {
input.close(); input.close();
output.finish(); output.finish();
@ -92,6 +83,18 @@ void FilterTransform::removeFilterIfNeed(Chunk & chunk)
void FilterTransform::transform(Chunk & chunk) void FilterTransform::transform(Chunk & chunk)
{ {
if (!initialized)
{
initialized = true;
/// Cannot check this in prepare. Because in prepare columns for set may be not created yet.
if (expression->checkColumnIsAlwaysFalse(filter_column_name))
{
stopReading();
chunk = Chunk(getOutputPort().getHeader().getColumns(), 0);
return;
}
}
size_t num_rows_before_filtration = chunk.getNumRows(); size_t num_rows_before_filtration = chunk.getNumRows();
auto columns = chunk.detachColumns(); auto columns = chunk.detachColumns();