#pragma once #include "CompressedReadBufferBase.h" #include #include namespace DB { class CompressedReadBuffer : public CompressedReadBufferBase, public BufferWithOwnMemory { private: size_t size_compressed = 0; bool nextImpl() override; public: CompressedReadBuffer(ReadBuffer & in_) : CompressedReadBufferBase(&in_), BufferWithOwnMemory(0) { } size_t readBig(char * to, size_t n) override; /// The compressed size of the current block. size_t getSizeCompressed() const { return size_compressed; } }; }