From 9abab40512e93d6c7f6eb15ba7bf23411f4cdaa7 Mon Sep 17 00:00:00 2001 From: Nikolai Kochetov Date: Wed, 23 Oct 2019 06:45:43 +0300 Subject: [PATCH] Added more comments. --- dbms/src/Processors/Pipe.h | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/dbms/src/Processors/Pipe.h b/dbms/src/Processors/Pipe.h index 55b397c82d6..872f04c339b 100644 --- a/dbms/src/Processors/Pipe.h +++ b/dbms/src/Processors/Pipe.h @@ -11,7 +11,11 @@ using Pipes = std::vector; class Pipe { public: + /// Create from source. It must have no input ports and single output. explicit Pipe(ProcessorPtr source); + /// Connect several pipes together with specified transform. + /// Transform must have the number of inputs equals to the number of pipes. And single output. + /// Will connect pipes outputs with transform inputs automatically. Pipe(Pipes && pipes, ProcessorPtr transform); Pipe(const Pipe & other) = delete;