| 217 | } |
| 218 | |
| 219 | void ReadData() { |
| 220 | auto reader = |
| 221 | ParquetFileReader::Open(std::make_shared<::arrow::io::BufferReader>(buffer_)); |
| 222 | auto metadata = reader->metadata(); |
| 223 | for (int i = 0; i < metadata->num_row_groups(); ++i) { |
| 224 | int64_t num_rows = metadata->RowGroup(i)->num_rows(); |
| 225 | auto row_group_reader = reader->RowGroup(i); |
| 226 | for (int j = 0; j < metadata->num_columns(); ++j) { |
| 227 | auto column_reader = row_group_reader->RecordReader(j); |
| 228 | ASSERT_EQ(column_reader->ReadRecords(num_rows + 1), num_rows); |
| 229 | } |
| 230 | } |
| 231 | } |
| 232 | |
| 233 | void Reset() { buffer_.reset(); } |
| 234 |
nothing calls this directly
no test coverage detected