| 94 | Type::type type_num() { return TestType::type_num; } |
| 95 | |
| 96 | void BuildReader(int64_t num_rows, |
| 97 | Compression::type compression = Compression::UNCOMPRESSED, |
| 98 | bool page_checksum_verify = false) { |
| 99 | ASSERT_OK_AND_ASSIGN(auto buffer, sink_->Finish()); |
| 100 | auto source = std::make_shared<::arrow::io::BufferReader>(buffer); |
| 101 | ReaderProperties readerProperties; |
| 102 | readerProperties.set_page_checksum_verification(page_checksum_verify); |
| 103 | std::unique_ptr<PageReader> page_reader = PageReader::Open( |
| 104 | std::move(source), num_rows, compression, readerProperties, *this->descr_); |
| 105 | reader_ = std::static_pointer_cast<TypedColumnReader<TestType>>( |
| 106 | ColumnReader::Make(this->descr_, std::move(page_reader))); |
| 107 | } |
| 108 | |
| 109 | std::shared_ptr<TypedColumnWriter<TestType>> BuildWriter( |
| 110 | int64_t output_size = SMALL_SIZE, |
no test coverage detected