| 44 | } |
| 45 | |
| 46 | WindowStep::WindowStep( |
| 47 | const SharedHeader & input_header_, |
| 48 | const WindowDescription & window_description_, |
| 49 | const std::vector<WindowFunctionDescription> & window_functions_, |
| 50 | bool streams_fan_out_) |
| 51 | : ITransformingStep(input_header_, std::make_shared<const Block>(addWindowFunctionResultColumns(*input_header_, window_functions_)), getTraits(!streams_fan_out_)) |
| 52 | , window_description(window_description_) |
| 53 | , window_functions(window_functions_) |
| 54 | , streams_fan_out(streams_fan_out_) |
| 55 | { |
| 56 | // We don't remove any columns, only add, so probably we don't have to update |
| 57 | // the output DataStream::distinct_columns. |
| 58 | |
| 59 | window_description.checkValid(); |
| 60 | |
| 61 | } |
| 62 | |
| 63 | void WindowStep::transformPipeline(QueryPipelineBuilder & pipeline, const BuildQueryPipelineSettings &) |
| 64 | { |
nothing calls this directly
no test coverage detected