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

Update TreeExecutor.

Browse Source
This commit is contained in:
Nikolai Kochetov 2020-02-18 12:03:17 +03:00
parent e6a30feed0
commit 426a8fd6a2
1 changed files with 16 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
dbms/src/Processors/Executors/TreeExecutorBlockInputStream.cpp
View File

@ -3,6 +3,7 @@
#include <Interpreters/ProcessList.h> #include <Interpreters/ProcessList.h>
#include <stack> #include <stack>
#include <Processors/Sources/SourceFromInputStream.h> #include <Processors/Sources/SourceFromInputStream.h>
#include <Processors/Transforms/AggregatingTransform.h>
namespace DB namespace DB
{ {
@ -215,7 +216,21 @@ Block TreeExecutorBlockInputStream::readImpl()
} }
if (input_port->hasData()) if (input_port->hasData())
return getHeader().cloneWithColumns(input_port->pull().detachColumns()); {
auto chunk = input_port->pull();
Block block = getHeader().cloneWithColumns(chunk.detachColumns());
if (auto & info = chunk.getChunkInfo())
{
if (auto * agg_info = typeid_cast<const AggregatedChunkInfo *>(info.get()))
{
block.info.bucket_num = agg_info->bucket_num;
block.info.is_overflows = agg_info->is_overflows;
}
}
return block;
}
execute(false); execute(false);
} }