style fix

This commit is contained in:
Yarik Briukhovetskyi 2024-03-07 15:29:07 +00:00
parent 852dd4c059
commit 47efd981f0
3 changed files with 2 additions and 8 deletions

View File

@ -128,7 +128,6 @@ bool SquashingTransform::isEnoughSize(size_t rows, size_t bytes) const
}
NewSquashingTransform::NewSquashingTransform(size_t min_block_size_rows_, size_t min_block_size_bytes_)
: min_block_size_rows(min_block_size_rows_)
, min_block_size_bytes(min_block_size_bytes_)
@ -160,10 +159,8 @@ Block NewSquashingTransform::addImpl(ReferenceType input_chunk)
const auto *info = getInfoFromChunk(input_chunk);
for (auto & one : info->chunks)
{
append(std::move(one), info->data_type);
}
{
Block to_return;
std::swap(to_return, accumulated_block);
@ -294,5 +291,4 @@ bool BalanceTransform::isEnoughSize(size_t rows, size_t bytes) const
|| (min_block_size_rows && rows >= min_block_size_rows)
|| (min_block_size_bytes && bytes >= min_block_size_bytes);
}
}

View File

@ -7,7 +7,7 @@ namespace DB
namespace ErrorCodes
{
extern const int MEMORY_LIMIT_EXCEEDED;
extern const int LOGICAL_ERROR;
}
BalancingChunksTransform::BalancingChunksTransform(const Block & header, size_t min_block_size_rows, size_t min_block_size_bytes, size_t max_memory_usage_, size_t num_ports)

View File

@ -16,8 +16,6 @@ public:
String getName() const override { return "BalancingChunksTransform"; }
InputPorts & getInputPorts() { return inputs; }
OutputPorts & getOutputPorts() { return outputs; }