| 444 | |
| 445 | template <typename TestType> |
| 446 | void TestPrimitiveWriter<TestType>::ReadColumnFully(Compression::type compression, |
| 447 | bool page_checksum_verify) { |
| 448 | int64_t total_values = static_cast<int64_t>(this->values_out_.size()); |
| 449 | BuildReader(total_values, compression, page_checksum_verify); |
| 450 | values_read_ = 0; |
| 451 | while (values_read_ < total_values) { |
| 452 | int64_t values_read_recently = 0; |
| 453 | reader_->ReadBatch( |
| 454 | static_cast<int>(this->values_out_.size()) - static_cast<int>(values_read_), |
| 455 | definition_levels_out_.data() + values_read_, |
| 456 | repetition_levels_out_.data() + values_read_, |
| 457 | this->values_out_ptr_ + values_read_, &values_read_recently); |
| 458 | values_read_ += values_read_recently; |
| 459 | } |
| 460 | this->SyncValuesOut(); |
| 461 | } |
| 462 | |
| 463 | template <> |
| 464 | void TestPrimitiveWriter<Int96Type>::ReadAndCompare(Compression::type compression, |
no test coverage detected