1 | #pragma once |
---|---|
2 | #include <Processors/IProcessor.h> |
3 | |
4 | namespace DB |
5 | { |
6 | |
7 | class NullSink : public IProcessor |
8 | { |
9 | public: |
10 | explicit NullSink(Block header) : IProcessor({std::move(header)}, {}) {} |
11 | String getName() const override { return "NullSink"; } |
12 | |
13 | Status prepare() override |
14 | { |
15 | inputs.front().close(); |
16 | return Status::Finished; |
17 | } |
18 | |
19 | InputPort & getPort() { return inputs.front(); } |
20 | }; |
21 | |
22 | } |
23 |