1#pragma once
2
3#include <DataStreams/IBlockInputStream.h>
4
5
6namespace DB
7{
8
9/// Empty stream of blocks of specified structure.
10class NullBlockInputStream : public IBlockInputStream
11{
12public:
13 NullBlockInputStream(const Block & header_) : header(header_) {}
14
15 Block getHeader() const override { return header; }
16 String getName() const override { return "Null"; }
17
18private:
19 Block header;
20
21 Block readImpl() override { return {}; }
22};
23
24}
25