| 224 | class SerializedPageReader : public PageReader { |
| 225 | public: |
| 226 | SerializedPageReader(std::shared_ptr<ArrowInputStream> stream, int64_t total_num_values, |
| 227 | Compression::type codec, const ReaderProperties& properties, |
| 228 | const CryptoContext* crypto_ctx, bool always_compressed) |
| 229 | : properties_(properties), |
| 230 | stream_(std::move(stream)), |
| 231 | decompression_buffer_(AllocateBuffer(properties_.memory_pool(), 0)), |
| 232 | page_ordinal_(0), |
| 233 | seen_num_values_(0), |
| 234 | total_num_values_(total_num_values) { |
| 235 | if (crypto_ctx != nullptr) { |
| 236 | crypto_ctx_ = *crypto_ctx; |
| 237 | InitDecryption(); |
| 238 | } |
| 239 | max_page_header_size_ = kDefaultMaxPageHeaderSize; |
| 240 | decompressor_ = GetCodec(codec); |
| 241 | always_compressed_ = always_compressed; |
| 242 | } |
| 243 | |
| 244 | // Implement the PageReader interface |
| 245 | // |
nothing calls this directly
no test coverage detected