ClickHouse/src/Processors/ConcatProcessor.h

33 lines
654 B
C++
Raw Normal View History

#pragma once
#include <Processors/IProcessor.h>
namespace DB
{
2020-08-08 00:47:03 +00:00
/** Has arbitrary non zero number of inputs and one output.
* All of them have the same structure.
*
* Pulls all data from first input, then all data from second input, etc...
* Doesn't do any heavy calculations.
* Preserves an order of data.
*/
2023-02-02 15:47:00 +00:00
class ConcatProcessor final : public IProcessor
{
public:
ConcatProcessor(const Block & header, size_t num_inputs);
String getName() const override { return "Concat"; }
Status prepare() override;
OutputPort & getOutputPort() { return outputs.front(); }
private:
InputPorts::iterator current_input;
};
}