Update test and err message

apache · May 16, 2024 · c082f8d · c082f8d
1 parent 762eb33
commit c082f8d
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 40 deletions.
diff --git a/cpp/src/parquet/column_reader.cc b/cpp/src/parquet/column_reader.cc
@@ -103,7 +103,7 @@ inline void CheckNumberDecoded(int64_t number_decoded, int64_t expected) {
 }
 
 constexpr std::string_view kErrorRepDefLevelNotMatchesNumValues =
-    "Number of decoded rep / def levels did less than num_values in page_header";
+    "Number of decoded rep / def levels did more or less than num_values in page_header";
 constexpr std::string_view kErrorRepDefLevelInEqual =
     "Number of decoded rep / def levels did not match";
 

diff --git a/cpp/src/parquet/column_reader_test.cc b/cpp/src/parquet/column_reader_test.cc
@@ -437,17 +437,16 @@ TEST_F(TestPrimitiveReader, TestReadValuesMissing) {
 TEST_F(TestPrimitiveReader, DefLevelNotExpected) {
   max_def_level_ = 1;
   max_rep_level_ = 0;
-  std::vector<bool> values(1, false);
-  // storing def-levels less than value in page-header
-  {
-    std::vector<int16_t> input_def_levels(1, 1);
+
+  auto do_check = [&](const std::vector<int16_t>& input_def_levels, int num_values) {
+    std::vector<bool> values(num_values, false);
     NodePtr type = schema::Boolean("a", Repetition::OPTIONAL);
     const ColumnDescriptor descr(type, max_def_level_, max_rep_level_);
 
     // The data page falls back to plain encoding
     std::shared_ptr<ResizableBuffer> dummy = AllocateBuffer();
     std::shared_ptr<DataPageV1> data_page = MakeDataPage<BooleanType>(
-        &descr, values, /*num_values=*/3, Encoding::PLAIN, /*indices=*/{},
+        &descr, values, /*num_values=*/num_values, Encoding::PLAIN, /*indices=*/{},
         /*indices_size=*/0, /*def_levels=*/input_def_levels, max_def_level_,
         /*rep_levels=*/{},
         /*max_rep_level=*/max_rep_level_);
@@ -456,7 +455,7 @@ TEST_F(TestPrimitiveReader, DefLevelNotExpected) {
     auto reader = static_cast<BoolReader*>(reader_.get());
     ASSERT_TRUE(reader->HasNext());
 
-    constexpr int batch_size = 3;
+    constexpr int batch_size = 10;
     std::vector<int16_t> def_levels(batch_size, 0);
     std::vector<int16_t> rep_levels(batch_size, 0);
     bool values_out[batch_size];
@@ -467,42 +466,20 @@ TEST_F(TestPrimitiveReader, DefLevelNotExpected) {
                             &values_read);
         },
         ParquetException,
-        ::testing::Property(&ParquetException::what,
-                            ::testing::HasSubstr("Number of decoded rep / def levels did "
-                                                 "less than num_values in page_header")));
+        ::testing::Property(
+            &ParquetException::what,
+            ::testing::HasSubstr("Number of decoded rep / def levels did "
+                                 "more or less than num_values in page_header")));
+  };
+  // storing def-levels less than value in page-header
+  {
+    std::vector<int16_t> input_def_levels(1, 1);
+    do_check(input_def_levels, /*num_values=*/3);
   }
-  //  storing def-levels more than value in page-header
+  // storing def-levels more than value in page-header
   {
     std::vector<int16_t> input_def_levels(2, 1);
-    NodePtr type = schema::Boolean("a", Repetition::OPTIONAL);
-    const ColumnDescriptor descr(type, max_def_level_, max_rep_level_);
-
-    // The data page falls back to plain encoding
-    std::shared_ptr<ResizableBuffer> dummy = AllocateBuffer();
-    std::shared_ptr<DataPageV1> data_page = MakeDataPage<BooleanType>(
-        &descr, values, /*num_values=*/1, Encoding::PLAIN, /*indices=*/{},
-        /*indices_size=*/0, /*def_levels=*/input_def_levels, max_def_level_,
-        /*rep_levels=*/{},
-        /*max_rep_level=*/max_rep_level_);
-    pages_.push_back(data_page);
-    InitReader(&descr);
-    auto reader = static_cast<BoolReader*>(reader_.get());
-    ASSERT_TRUE(reader->HasNext());
-
-    constexpr int batch_size = 3;
-    std::vector<int16_t> def_levels(batch_size, 0);
-    std::vector<int16_t> rep_levels(batch_size, 0);
-    bool values_out[batch_size];
-    int64_t values_read;
-    EXPECT_THROW_THAT(
-        [&]() {
-          reader->ReadBatch(batch_size, def_levels.data(), rep_levels.data(), values_out,
-                            &values_read);
-        },
-        ParquetException,
-        ::testing::Property(&ParquetException::what,
-                            ::testing::HasSubstr("Number of decoded rep / def levels did "
-                                                 "less than num_values in page_header")));
+    do_check(input_def_levels, /*num_values=*/1);
   }
 }