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

Revert "fix SimpleSquashingChunksTransform"

Browse Source 
This reverts commit f1f5dfc83a.
This commit is contained in:
vdimir 2024-07-06 16:35:54 +00:00
parent f1f5dfc83a
commit 06734b351e
No known key found for this signature in database
GPG Key ID: 6EE4CE2BEDC51862
2 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/Processors/Transforms/SquashingTransform.cpp
View File

@ -58,13 +58,14 @@ void SquashingTransform::work()
SimpleSquashingChunksTransform::SimpleSquashingChunksTransform(
const Block & header, size_t min_block_size_rows, size_t min_block_size_bytes)
: IInflatingTransform(header, header), squashing(header, min_block_size_rows, min_block_size_bytes)
: IInflatingTransform(header, header), squashing(min_block_size_rows, min_block_size_bytes)
{
}
void SimpleSquashingChunksTransform::consume(Chunk chunk)
{
squashed_chunk = squashing.add(std::move(chunk));
Block current_block = squashing.add(getInputPort().getHeader().cloneWithColumns(chunk.detachColumns()));
squashed_chunk.setColumns(current_block.getColumns(), current_block.rows());
}
Chunk SimpleSquashingChunksTransform::generate()
@ -82,7 +83,8 @@ bool SimpleSquashingChunksTransform::canGenerate()
Chunk SimpleSquashingChunksTransform::getRemaining()
{
squashed_chunk = squashing.flush();
Block current_block = squashing.add({});
squashed_chunk.setColumns(current_block.getColumns(), current_block.rows());
return std::move(squashed_chunk);
}

2
src/Processors/Transforms/SquashingTransform.h
View File

@ -44,7 +44,7 @@ protected:
Chunk getRemaining() override;
private:
Squashing squashing;
SquashingTransform squashing;
Chunk squashed_chunk;
};