| 1411 | bool read_dense_for_nullable() { return GetParam(); } |
| 1412 | |
| 1413 | void MakeRecordReader(int levels_per_page, int num_pages, int FLBA_type_length) { |
| 1414 | levels_per_page_ = levels_per_page; |
| 1415 | FLBA_type_length_ = FLBA_type_length; |
| 1416 | internal::LevelInfo level_info; |
| 1417 | level_info.def_level = 1; |
| 1418 | level_info.rep_level = 0; |
| 1419 | NodePtr type = ::parquet::schema::PrimitiveNode::Make( |
| 1420 | "b", Repetition::OPTIONAL, Type::FIXED_LEN_BYTE_ARRAY, ConvertedType::NONE, |
| 1421 | FLBA_type_length_); |
| 1422 | descr_ = std::make_unique<ColumnDescriptor>(type, level_info.def_level, |
| 1423 | level_info.rep_level); |
| 1424 | MakePages<FLBAType>(descr_.get(), num_pages, levels_per_page, def_levels_, |
| 1425 | rep_levels_, values_, buffer_, pages_, Encoding::PLAIN); |
| 1426 | auto pager = std::make_unique<MockPageReader>(pages_); |
| 1427 | record_reader_ = internal::RecordReader::Make( |
| 1428 | descr_.get(), level_info, ::arrow::default_memory_pool(), |
| 1429 | /*read_dictionary=*/false, read_dense_for_nullable()); |
| 1430 | record_reader_->SetPageReader(std::move(pager)); |
| 1431 | } |
| 1432 | |
| 1433 | // Returns expected values in row range. |
| 1434 | // We need this since some values are null. |
nothing calls this directly
no test coverage detected