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

use concatenateBlocks

Browse Source
This commit is contained in:
lgbo-ustc 2022-04-21 14:10:09 +08:00
parent 60964b207d
commit eac810ed85
1 changed files with 1 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
src/Interpreters/ConcurrentHashJoin.cpp
View File

@ -108,33 +108,7 @@ void ConcurrentHashJoin::joinBlock(Block & block, std::shared_ptr<ExtraBlock> &
throw Exception(ErrorCodes::LOGICAL_ERROR, "not_processed should be empty");
}
ColumnsWithTypeAndName final_columns;
MutableColumns mutable_final_columns;
NamesAndTypesList names_and_types = dispatched_blocks[0].getNamesAndTypesList();
auto types = names_and_types.getTypes();
for (auto & dispatched_block : dispatched_blocks)
{
for (size_t pos = 0; pos < dispatched_block.columns(); ++pos)
{
auto & from_column = dispatched_block.getByPosition(pos);
if (mutable_final_columns.size() <= pos)
{
mutable_final_columns.emplace_back(from_column.column->cloneEmpty());
}
if (!from_column.column->empty())
{
mutable_final_columns[pos]->insertRangeFrom(*from_column.column, 0, from_column.column->size());
}
}
}
size_t i = 0;
for (auto & name_and_type : names_and_types)
{
final_columns.emplace_back(ColumnWithTypeAndName(std::move(mutable_final_columns[i]), name_and_type.type, name_and_type.name));
i += 1;
}
block = Block(final_columns);
block = concatenateBlocks(dispatched_blocks);
}
void ConcurrentHashJoin::checkTypesOfKeys(const Block & block) const