This commit is contained in:
Alexey Milovidov 2018-05-06 14:34:16 +03:00
parent 63625c0a30
commit 9da677719c

View File

@ -288,7 +288,8 @@ void ExpressionAction::prepare(Block & sample_block)
}
}
size_t ExpressionAction::getInputRowsCount(Block & block, std::unordered_map<std::string, size_t> & input_rows_counts) const {
size_t ExpressionAction::getInputRowsCount(Block & block, std::unordered_map<std::string, size_t> & input_rows_counts) const
{
auto it = input_rows_counts.find(row_projection_column);
size_t projection_space_dimension;
if (it == input_rows_counts.end())
@ -314,6 +315,7 @@ size_t ExpressionAction::getInputRowsCount(Block & block, std::unordered_map<std
{
parent_space_dimension = block.getByName(row_projection_column).column->size();
}
return is_row_projection_complementary ? parent_space_dimension - projection_space_dimension : projection_space_dimension;
}