diff --git a/dbms/src/Processors/LimitTransform.h b/dbms/src/Processors/LimitTransform.h index 2472adb14d8..eea7aa4bf24 100644 --- a/dbms/src/Processors/LimitTransform.h +++ b/dbms/src/Processors/LimitTransform.h @@ -9,6 +9,8 @@ namespace DB class LimitTransform : public IProcessor { public: + /// Common counter of read rows. It is shared between several streams. + /// Is used for pre-limit. Needed to skip main limit phase and avoid the resizing pipeline to single stream. struct LimitState { std::atomic total_read_rows = 0;