From 027f9913168a8f6f77fc4883166f1ef302f5fe42 Mon Sep 17 00:00:00 2001 From: yuzelin Date: Mon, 23 Dec 2024 12:08:40 +0800 Subject: [PATCH] [hotfix] Fix typo --- .../paimon/format/parquet/reader/NestedColumnReader.java | 8 ++++---- .../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 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