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));

Reply via email to