| 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 | StatisticsMinMaxField stats_min_max_field) |
| 230 | : properties_(properties), |
| 231 | stream_(std::move(stream)), |
| 232 | decompression_buffer_(AllocateBuffer(properties_.memory_pool(), 0)), |
| 233 | page_ordinal_(0), |
| 234 | seen_num_values_(0), |
| 235 | total_num_values_(total_num_values), |
| 236 | stats_min_max_field_(stats_min_max_field) { |
| 237 | if (crypto_ctx != nullptr) { |
| 238 | crypto_ctx_ = *crypto_ctx; |
| 239 | InitDecryption(); |
| 240 | } |
| 241 | max_page_header_size_ = kDefaultMaxPageHeaderSize; |
| 242 | decompressor_ = GetCodec(codec); |
| 243 | always_compressed_ = always_compressed; |
| 244 | } |
| 245 | |
| 246 | // Implement the PageReader interface |
| 247 | // |
nothing calls this directly
no test coverage detected