| 87 | |
| 88 | |
| 89 | CreatingSetsStep::CreatingSetsStep(SharedHeaders input_headers_) |
| 90 | { |
| 91 | if (input_headers_.empty()) |
| 92 | throw Exception(ErrorCodes::LOGICAL_ERROR, "CreatingSetsStep cannot be created with no inputs"); |
| 93 | |
| 94 | input_headers = std::move(input_headers_); |
| 95 | output_header = input_headers.front(); |
| 96 | |
| 97 | for (size_t i = 1; i < input_headers.size(); ++i) |
| 98 | if (!input_headers[i]->empty()) |
| 99 | throw Exception(ErrorCodes::LOGICAL_ERROR, "Creating set input must have empty header. Got: {}", |
| 100 | input_headers[i]->dumpStructure()); |
| 101 | } |
| 102 | |
| 103 | QueryPipelineBuilderPtr CreatingSetsStep::updatePipeline(QueryPipelineBuilders pipelines, const BuildQueryPipelineSettings &) |
| 104 | { |
nothing calls this directly
no test coverage detected