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

dbms: development [#CONV-5097].

Browse Source
This commit is contained in:
Alexey Milovidov 2012-06-22 15:39:13 +00:00
parent b4a40177ec
commit fc476bf78e
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
dbms/src/Interpreters/InterpreterSelectQuery.cpp
View File

@ -261,7 +261,16 @@ void InterpreterSelectQuery::executeAggregation(BlockInputStreams & streams, Exp
BlockInputStreamPtr & stream = streams[0];
/// Если потоков несколько, то выполняем параллельную агрегацию
/** Если истчоников слишком много, то склеим их в один (TODO: в max_threads) источников.
* (Иначе агрегация в каждом маленьком источнике, а затем объединение состояний, слишком неэффективна.)
*/
if (streams.size() > context.settings.max_threads)
{
streams[0] = new UnionBlockInputStream(streams, context.settings.max_threads);
streams.resize(1);
}
/// Если источников несколько, то выполняем параллельную агрегацию
if (streams.size() > 1)
{
stream = maybeAsynchronous(new ParallelAggregatingBlockInputStream(streams, expression, context.settings.max_threads), context.settings.asynchronous);