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

Fix build

Browse Source
This commit is contained in:
Nikolai Kochetov 2020-11-03 22:33:29 +03:00
parent 54a9b80a11
commit 4ce88298d7
1 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/Processors/QueryPlan/ReadFromStorageStep.cpp
View File

@ -38,19 +38,17 @@ ReadFromStorageStep::ReadFromStorageStep(
{
if (query_info.prewhere_info->alias_actions)
{
auto alias_actions = query_info.prewhere_info->alias_actions->buildExpressions();
pipe.addSimpleTransform([&](const Block & header)
{
return std::make_shared<ExpressionTransform>(header, alias_actions);
return std::make_shared<ExpressionTransform>(header, query_info.prewhere_info->alias_actions);
});
}
auto prewhere_actions = query_info.prewhere_info->prewhere_actions->buildExpressions();
pipe.addSimpleTransform([&](const Block & header)
{
return std::make_shared<FilterTransform>(
header,
prewhere_actions,
query_info.prewhere_info->prewhere_actions,
query_info.prewhere_info->prewhere_column_name,
query_info.prewhere_info->remove_prewhere_column);
});
@ -61,10 +59,10 @@ ReadFromStorageStep::ReadFromStorageStep(
// This leads to mismatched header in distributed table
if (query_info.prewhere_info->remove_columns_actions)
{
auto remove_actions = query_info.prewhere_info->remove_columns_actions->buildExpressions();
pipe.addSimpleTransform([&](const Block & header)
{
return std::make_shared<ExpressionTransform>(header, remove_actions);
return std::make_shared<ExpressionTransform>(
header, query_info.prewhere_info->remove_columns_actions);
});
}
}