| 101 | } |
| 102 | |
| 103 | void MergingAggregatedStep::setInputStreams(const DataStreams & input_streams_) |
| 104 | { |
| 105 | // TODO: what if input_streams and params->getHeader() are inconsistent |
| 106 | input_streams = input_streams_; |
| 107 | output_stream->header = appendGroupingColumns(params->getHeader(), groupings); |
| 108 | } |
| 109 | |
| 110 | void MergingAggregatedStep::transformPipeline(QueryPipeline & pipeline, const BuildQueryPipelineSettings & build_settings) |
| 111 | { |
nothing calls this directly
no test coverage detected