File tree Expand file tree Collapse file tree 2 files changed +10
-0
lines changed
Expand file tree Collapse file tree 2 files changed +10
-0
lines changed Original file line number Diff line number Diff line change @@ -76,6 +76,11 @@ class AggregatingStep : public ITransformingStep
7676 // / Argument input_stream would be the second input (from projection).
7777 std::unique_ptr<AggregatingProjectionStep> convertToAggregatingProjection (const DataStream & input_stream) const ;
7878
79+ const Processors & getProcessors () const override
80+ {
81+ return aggregating;
82+ }
83+
7984private:
8085 void updateOutputStream () override ;
8186
Original file line number Diff line number Diff line change @@ -107,6 +107,11 @@ class IQueryPlanStep
107107 // / Append extra processors for this step.
108108 void appendExtraProcessors (const Processors & extra_processors);
109109
110+ virtual const Processors & getProcessors () const
111+ {
112+ return processors;
113+ }
114+
110115protected:
111116 DataStreams input_streams;
112117 std::optional<DataStream> output_stream;
You can’t perform that action at this time.
0 commit comments