1#pragma once
2
3#include <Core/Block.h>
4#include <Processors/Formats/IRowInputFormat.h>
5
6
7namespace DB
8{
9
10class ReadBuffer;
11
12
13/** A stream for inputting data in a binary line-by-line format.
14 */
15class BinaryRowInputFormat : public IRowInputFormat
16{
17public:
18 BinaryRowInputFormat(ReadBuffer & in_, Block header, Params params_, bool with_names_, bool with_types_);
19
20 bool readRow(MutableColumns & columns, RowReadExtension &) override;
21 void readPrefix() override;
22
23 String getName() const override { return "BinaryRowInputFormat"; }
24
25private:
26 bool with_names;
27 bool with_types;
28};
29
30}
31