| 22 | } |
| 23 | |
| 24 | void InputSelectorStep::updateOutputHeader() |
| 25 | { |
| 26 | if (!input_headers[0]->empty()) |
| 27 | throw Exception(ErrorCodes::LOGICAL_ERROR, "InputSelectorStep: signal header must be empty"); |
| 28 | |
| 29 | assertBlocksHaveEqualStructure(*input_headers[1], *input_headers[2], "InputSelectorStep"); |
| 30 | |
| 31 | output_header = input_headers[1]; |
| 32 | } |
| 33 | |
| 34 | /// If the pipeline header has extra columns not in the expected header, add an ExpressionTransform to drop them. |
| 35 | static void dropExtraColumns(QueryPipelineBuilder & pipeline, const Block & expected_header) |
nothing calls this directly
no test coverage detected