From 3ad2d4380d3826df184ec5dcc142bb789f7ab69d Mon Sep 17 00:00:00 2001 From: LiuNeng <1398775315@qq.com> Date: Tue, 25 Apr 2023 11:38:50 +0800 Subject: [PATCH] export processors getter in QueryPlanStep --- src/Processors/QueryPlan/AggregatingStep.h | 5 +++++ src/Processors/QueryPlan/IQueryPlanStep.h | 5 +++++ 2 files changed, 10 insertions(+) diff --git a/src/Processors/QueryPlan/AggregatingStep.h b/src/Processors/QueryPlan/AggregatingStep.h index 3d128d788ac9..ee5a0cd75b53 100644 --- a/src/Processors/QueryPlan/AggregatingStep.h +++ b/src/Processors/QueryPlan/AggregatingStep.h @@ -76,6 +76,11 @@ class AggregatingStep : public ITransformingStep /// Argument input_stream would be the second input (from projection). std::unique_ptr convertToAggregatingProjection(const DataStream & input_stream) const; + const Processors & getProcessors() const override + { + return aggregating; + } + private: void updateOutputStream() override; diff --git a/src/Processors/QueryPlan/IQueryPlanStep.h b/src/Processors/QueryPlan/IQueryPlanStep.h index a608c6f80583..b321192c9377 100644 --- a/src/Processors/QueryPlan/IQueryPlanStep.h +++ b/src/Processors/QueryPlan/IQueryPlanStep.h @@ -107,6 +107,11 @@ class IQueryPlanStep /// Append extra processors for this step. void appendExtraProcessors(const Processors & extra_processors); + virtual const Processors & getProcessors() const + { + return processors; + } + protected: DataStreams input_streams; std::optional output_stream;