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