This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new bbcece8b80 [hotfix] Fix typo in NestedColumnReader and 
NestedPrimitiveColumnReader (#4752)
bbcece8b80 is described below

commit bbcece8b80581f6d37b2272a22409732325fc54b
Author: yuzelin <[email protected]>
AuthorDate: Mon Dec 23 13:06:06 2024 +0800

    [hotfix] Fix typo in NestedColumnReader and NestedPrimitiveColumnReader 
(#4752)
    
    Co-authored-by: yuzelin <[email protected]>
---
 .../apache/paimon/format/parquet/reader/NestedColumnReader.java   | 8 ++++----
 .../paimon/format/parquet/reader/NestedPrimitiveColumnReader.java | 2 +-
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/NestedColumnReader.java
 
b/paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/NestedColumnReader.java
index 3724014e62..0dab883208 100644
--- 
a/paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/NestedColumnReader.java
+++ 
b/paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/NestedColumnReader.java
@@ -160,7 +160,7 @@ public class NestedColumnReader implements 
ColumnReader<WritableColumnVector> {
         }
 
         if (hasNull) {
-            setFieldNullFalg(isNull, heapRowVector);
+            setFieldNullFlag(isNull, heapRowVector);
         }
         return Pair.of(levelDelegation, heapRowVector);
     }
@@ -202,7 +202,7 @@ public class NestedColumnReader implements 
ColumnReader<WritableColumnVector> {
         }
 
         if (collectionPosition.getIsNull() != null) {
-            setFieldNullFalg(collectionPosition.getIsNull(), mapVector);
+            setFieldNullFlag(collectionPosition.getIsNull(), mapVector);
         }
 
         mapVector.setLengths(collectionPosition.getLength());
@@ -240,7 +240,7 @@ public class NestedColumnReader implements 
ColumnReader<WritableColumnVector> {
         }
 
         if (collectionPosition.getIsNull() != null) {
-            setFieldNullFalg(collectionPosition.getIsNull(), arrayVector);
+            setFieldNullFlag(collectionPosition.getIsNull(), arrayVector);
         }
         arrayVector.setLengths(collectionPosition.getLength());
         arrayVector.setOffsets(collectionPosition.getOffsets());
@@ -266,7 +266,7 @@ public class NestedColumnReader implements 
ColumnReader<WritableColumnVector> {
         return Pair.of(reader.getLevelDelegation(), writableColumnVector);
     }
 
-    private static void setFieldNullFalg(boolean[] nullFlags, 
AbstractHeapVector vector) {
+    private static void setFieldNullFlag(boolean[] nullFlags, 
AbstractHeapVector vector) {
         for (int index = 0; index < vector.getLen() && index < 
nullFlags.length; index++) {
             if (nullFlags[index]) {
                 vector.setNullAt(index);
diff --git 
a/paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/NestedPrimitiveColumnReader.java
 
b/paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/NestedPrimitiveColumnReader.java
index 69b0fa5744..78c335dab0 100644
--- 
a/paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/NestedPrimitiveColumnReader.java
+++ 
b/paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/NestedPrimitiveColumnReader.java
@@ -254,7 +254,7 @@ public class NestedPrimitiveColumnReader implements 
ColumnReader<WritableColumnV
         // Compute the number of values we want to read in this page.
         if (readState.valuesToReadInPage == 0) {
             int pageValueCount = readPage();
-            // 返回当前 page 的数据量
+            //  return value count in current page
             if (pageValueCount < 0) {
                 // we've read all the pages; this could happen when we're 
reading a repeated list
                 // and we

Reply via email to