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 3724014e6287..0dab88320863 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 @@ private Pair readRow( } if (hasNull) { - setFieldNullFalg(isNull, heapRowVector); + setFieldNullFlag(isNull, heapRowVector); } return Pair.of(levelDelegation, heapRowVector); } @@ -202,7 +202,7 @@ private Pair readMap( } if (collectionPosition.getIsNull() != null) { - setFieldNullFalg(collectionPosition.getIsNull(), mapVector); + setFieldNullFlag(collectionPosition.getIsNull(), mapVector); } mapVector.setLengths(collectionPosition.getLength()); @@ -240,7 +240,7 @@ private Pair readArray( } if (collectionPosition.getIsNull() != null) { - setFieldNullFalg(collectionPosition.getIsNull(), arrayVector); + setFieldNullFlag(collectionPosition.getIsNull(), arrayVector); } arrayVector.setLengths(collectionPosition.getLength()); arrayVector.setOffsets(collectionPosition.getOffsets()); @@ -266,7 +266,7 @@ private Pair readPrimitive( 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 69b0fa574418..78c335dab01c 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 @@ private int readPageIfNeed() throws IOException { // 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