diff --git a/dbms/src/Processors/LimitTransform.h b/dbms/src/Processors/LimitTransform.h index f7a5a8d364d..3398e86b15a 100644 --- a/dbms/src/Processors/LimitTransform.h +++ b/dbms/src/Processors/LimitTransform.h @@ -61,6 +61,9 @@ public: Status preparePair(PortsData & data); void splitChunk(PortsData & data); + InputPort & getInputPort() { return inputs.front(); } + OutputPort & getOutputPort() { return outputs.front(); } + size_t getRowsBeforeLimitAtLeast() const { return rows_before_limit_at_least; } };