| 24 | } |
| 25 | |
| 26 | static void checkSource(const IProcessor & source) |
| 27 | { |
| 28 | if (!source.getInputs().empty()) |
| 29 | throw Exception( |
| 30 | ErrorCodes::LOGICAL_ERROR, |
| 31 | "Source for pipe shouldn't have any input, but {} has {} inputs", |
| 32 | source.getName(), |
| 33 | source.getInputs().size()); |
| 34 | |
| 35 | if (source.getOutputs().size() != 1) |
| 36 | throw Exception( |
| 37 | ErrorCodes::LOGICAL_ERROR, |
| 38 | "Source for pipe should have single output, but {} has {} outputs", |
| 39 | source.getName(), |
| 40 | source.getOutputs().size()); |
| 41 | } |
| 42 | |
| 43 | static OutputPort * uniteExtremes(const OutputPortRawPtrs & ports, SharedHeader header, Processors & processors) |
| 44 | { |
no test coverage detected