From 2f8435813c4548daa10ca020ca02a05c91614530 Mon Sep 17 00:00:00 2001 From: FawnD2 Date: Mon, 4 May 2020 17:49:13 +0300 Subject: [PATCH] Remove unused stream --- .../Formats/Impl/ArrowBufferedStreams.h | 26 ------------------- 1 file changed, 26 deletions(-) diff --git a/src/Processors/Formats/Impl/ArrowBufferedStreams.h b/src/Processors/Formats/Impl/ArrowBufferedStreams.h index 250174564ba..42127f45157 100644 --- a/src/Processors/Formats/Impl/ArrowBufferedStreams.h +++ b/src/Processors/Formats/Impl/ArrowBufferedStreams.h @@ -10,32 +10,6 @@ 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 { public: