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

optimize

Browse Source
This commit is contained in:
CurtizJ 2018-09-20 13:44:13 +03:00
parent 31bf960bfe
commit f9ff586415
2 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
dbms/src/DataStreams/CubeBlockInputStream.cpp
View File

@ -49,8 +49,9 @@ Block CubeBlockInputStream::readImpl()
{
if (!((mask >> i) & 1))
{
auto & current = cube_block.getByPosition(keys[keys.size() - i - 1]);
current.column = current.column->cloneEmpty()->cloneResized(cube_block.rows());
size_t pos = keys.size() - i - 1;
auto & current = cube_block.getByPosition(keys[pos]);
current.column = empty_block.getByPosition(pos).column->cloneResized(cube_block.rows());
}
}
@ -60,6 +61,7 @@ Block CubeBlockInputStream::readImpl()
}
source_block = children[0]->read();
empty_block = source_block.cloneEmpty();
Block finalized = source_block;
finalizeBlock(finalized);
mask = (1 << keys.size()) - 1;

1
dbms/src/DataStreams/CubeBlockInputStream.h
View File

@ -36,6 +36,7 @@ private:
ColumnNumbers keys;
UInt32 mask = 0;
Block source_block;
Block empty_block;
};
}