Minor modification

This commit is contained in:
Alexey Milovidov 2020-05-17 10:43:23 +03:00
parent f2d438b79f
commit c33373f7fb
2 changed files with 5 additions and 5 deletions

View File

@ -38,6 +38,9 @@ private:
VolumePtr tmp_volume;
size_t min_free_disk_space;
size_t sum_rows_in_blocks = 0;
size_t sum_bytes_in_blocks = 0;
Logger * log = &Logger::get("MergeSortingTransform");
/// If remerge doesn't save memory at least several times, mark it as useless and don't do it anymore.

View File

@ -66,8 +66,8 @@ class SortingTransform : public IProcessor
public:
/// limit - if not 0, allowed to return just first 'limit' rows in sorted order.
SortingTransform(const Block & header,
const SortDescription & description_,
size_t max_merged_block_size_, UInt64 limit_);
const SortDescription & description_,
size_t max_merged_block_size_, UInt64 limit_);
~SortingTransform() override;
@ -83,9 +83,6 @@ protected:
size_t max_merged_block_size;
UInt64 limit;
size_t sum_rows_in_blocks = 0;
size_t sum_bytes_in_blocks = 0;
/// Before operation, will remove constant columns from blocks. And after, place constant columns back.
/// (to avoid excessive virtual function calls and because constants cannot be serialized in Native format for temporary files)
/// Save original block structure here.