1#pragma once
2#include <Processors/IProcessor.h>
3
4namespace DB
5{
6
7class NullSink : public IProcessor
8{
9public:
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