Skip to content

Commit

Permalink
[hotfix] Fix typo
Browse files Browse the repository at this point in the history
  • Loading branch information
yuzelin committed Dec 23, 2024
1 parent b50040a commit 027f991
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -160,7 +160,7 @@ private Pair<LevelDelegation, WritableColumnVector> readRow(
}

if (hasNull) {
setFieldNullFalg(isNull, heapRowVector);
setFieldNullFlag(isNull, heapRowVector);
}
return Pair.of(levelDelegation, heapRowVector);
}
Expand Down Expand Up @@ -202,7 +202,7 @@ private Pair<LevelDelegation, WritableColumnVector> readMap(
}

if (collectionPosition.getIsNull() != null) {
setFieldNullFalg(collectionPosition.getIsNull(), mapVector);
setFieldNullFlag(collectionPosition.getIsNull(), mapVector);
}

mapVector.setLengths(collectionPosition.getLength());
Expand Down Expand Up @@ -240,7 +240,7 @@ private Pair<LevelDelegation, WritableColumnVector> readArray(
}

if (collectionPosition.getIsNull() != null) {
setFieldNullFalg(collectionPosition.getIsNull(), arrayVector);
setFieldNullFlag(collectionPosition.getIsNull(), arrayVector);
}
arrayVector.setLengths(collectionPosition.getLength());
arrayVector.setOffsets(collectionPosition.getOffsets());
Expand All @@ -266,7 +266,7 @@ private Pair<LevelDelegation, WritableColumnVector> 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);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit 027f991

Please sign in to comment.