thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-29 19:12:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

Remove unused stream

Browse Source
This commit is contained in:
FawnD2 2020-05-04 17:49:13 +03:00
parent da0a908d27
commit 2f8435813c
1 changed files with 0 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/Processors/Formats/Impl/ArrowBufferedStreams.h
View File

@ -10,32 +10,6 @@
namespace DB namespace DB
{ {
class ArrowBufferedInputStream : public arrow::io::InputStream
{
public:
explicit ArrowBufferedInputStream(ReadBuffer & in_);
// FileInterface
::arrow::Status Close() override;
::arrow::Status Tell(int64_t * position) const override;
bool closed() const override { return !is_open; }
// Readable
::arrow::Status Read(int64_t nbytes, int64_t* bytes_read, void * out) override;
// Does not copy if not necessary
::arrow::Status Read(int64_t nbytes, std::shared_ptr<::arrow::Buffer> * out) override;
private:
ReadBuffer & in;
int64_t total_length = 0;
bool is_open = false;
ARROW_DISALLOW_COPY_AND_ASSIGN(ArrowBufferedInputStream);
};
class ArrowBufferedOutputStream : public arrow::io::OutputStream class ArrowBufferedOutputStream : public arrow::io::OutputStream
{ {
public: public: