diff --git a/src/Processors/Transforms/MergeSortingTransform.h b/src/Processors/Transforms/MergeSortingTransform.h index a8786e5a034..043cb3f36c1 100644 --- a/src/Processors/Transforms/MergeSortingTransform.h +++ b/src/Processors/Transforms/MergeSortingTransform.h @@ -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. diff --git a/src/Processors/Transforms/SortingTransform.h b/src/Processors/Transforms/SortingTransform.h index 49bdf303c7f..9178991f324 100644 --- a/src/Processors/Transforms/SortingTransform.h +++ b/src/Processors/Transforms/SortingTransform.h @@ -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.