This is an automated email from the ASF dual-hosted git repository.
blue pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iceberg.git
The following commit(s) were added to refs/heads/master by this push:
new 32ce969 Spark: Fix typo for row position vector name (#2625)
32ce969 is described below
commit 32ce969218b75915cb7396c541bdc19f4ac8bd9f
Author: Chen, Junjie <[email protected]>
AuthorDate: Mon May 24 06:15:15 2021 +0800
Spark: Fix typo for row position vector name (#2625)
---
.../{RowPostitionColumnVector.java => RowPositionColumnVector.java} | 4 ++--
.../iceberg/spark/data/vectorized/VectorizedSparkOrcReaders.java | 2 +-
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git
a/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/RowPostitionColumnVector.java
b/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/RowPositionColumnVector.java
similarity index 96%
rename from
spark/src/main/java/org/apache/iceberg/spark/data/vectorized/RowPostitionColumnVector.java
rename to
spark/src/main/java/org/apache/iceberg/spark/data/vectorized/RowPositionColumnVector.java
index 8859b50..f0d35c6 100644
---
a/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/RowPostitionColumnVector.java
+++
b/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/RowPositionColumnVector.java
@@ -27,11 +27,11 @@ import org.apache.spark.sql.vectorized.ColumnarArray;
import org.apache.spark.sql.vectorized.ColumnarMap;
import org.apache.spark.unsafe.types.UTF8String;
-public class RowPostitionColumnVector extends ColumnVector {
+public class RowPositionColumnVector extends ColumnVector {
private final long batchOffsetInFile;
- RowPostitionColumnVector(long batchOffsetInFile) {
+ RowPositionColumnVector(long batchOffsetInFile) {
super(SparkSchemaUtil.convert(Types.LongType.get()));
this.batchOffsetInFile = batchOffsetInFile;
}
diff --git
a/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/VectorizedSparkOrcReaders.java
b/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/VectorizedSparkOrcReaders.java
index 160e4db..c3c5499 100644
---
a/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/VectorizedSparkOrcReaders.java
+++
b/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/VectorizedSparkOrcReaders.java
@@ -405,7 +405,7 @@ public class VectorizedSparkOrcReaders {
if (idToConstant.containsKey(field.fieldId())) {
fieldVectors.add(new ConstantColumnVector(field.type(), batchSize,
idToConstant.get(field.fieldId())));
} else if (field.equals(MetadataColumns.ROW_POSITION)) {
- fieldVectors.add(new RowPostitionColumnVector(batchOffsetInFile));
+ fieldVectors.add(new RowPositionColumnVector(batchOffsetInFile));
} else {
fieldVectors.add(fieldConverters.get(vectorIndex)
.convert(structVector.fields[vectorIndex], batchSize,
batchOffsetInFile));