| 2318 | } |
| 2319 | |
| 2320 | uint8_t* EnsureDecodeBuffer(int64_t min_values) { |
| 2321 | const int64_t size = this->type_length_ * min_values; |
| 2322 | if (!decode_buffer_ || decode_buffer_->size() < size) { |
| 2323 | const auto alloc_size = ::arrow::bit_util::NextPower2(size); |
| 2324 | PARQUET_ASSIGN_OR_THROW(decode_buffer_, ::arrow::AllocateBuffer(alloc_size)); |
| 2325 | } |
| 2326 | return decode_buffer_->mutable_data(); |
| 2327 | } |
| 2328 | |
| 2329 | int stride_{0}; |
| 2330 | std::shared_ptr<Buffer> decode_buffer_; |
no test coverage detected