#pragma once #include #include namespace DB { /// Executes OFFSET (without LIMIT). See OffsetTransform. class OffsetStep : public ITransformingStep { public: OffsetStep(const Header & input_header_, size_t offset_); String getName() const override { return "Offset"; } void transformPipeline(QueryPipelineBuilder & pipeline, const BuildQueryPipelineSettings &) override; void describeActions(JSONBuilder::JSONMap & map) const override; void describeActions(FormatSettings & settings) const override; private: void updateOutputHeader() override { output_header = input_headers.front(); } size_t offset; }; }