[parquet-mr] branch master updated: PARQUET-2112: Fix typo in MessageColumnIO (#943)

[shangxinli]

This is an automated email from the ASF dual-hosted git repository.

shangxinli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/parquet-mr.git


The following commit(s) were added to refs/heads/master by this push:
     new 300200e  PARQUET-2112: Fix typo in MessageColumnIO (#943)
300200e is described below

commit 300200eb72b9f16df36d9a68cf762683234aeb08
Author: Xinli Shang <sha...@uber.com>
AuthorDate: Mon Jan 24 21:30:19 2022 -0800

    PARQUET-2112: Fix typo in MessageColumnIO (#943)
    
    * PARQUET-2112: Fix typo in MessageColumnIO
    
    * Address feedback
---
 .../org/apache/parquet/io/MessageColumnIO.java     | 22 +++++++++++-----------
 1 file changed, 11 insertions(+), 11 deletions(-)

diff --git 
a/parquet-column/src/main/java/org/apache/parquet/io/MessageColumnIO.java 
b/parquet-column/src/main/java/org/apache/parquet/io/MessageColumnIO.java
index 0496c51..793668a 100644
--- a/parquet-column/src/main/java/org/apache/parquet/io/MessageColumnIO.java
+++ b/parquet-column/src/main/java/org/apache/parquet/io/MessageColumnIO.java
@@ -186,32 +186,32 @@ public class MessageColumnIO extends GroupColumnIO {
     private int currentLevel = 0;
 
     private class FieldsMarker {
-      private BitSet vistedIndexes = new BitSet();
+      private BitSet visitedIndexes = new BitSet();
 
       @Override
       public String toString() {
-        return "VistedIndex{" +
-            "vistedIndexes=" + vistedIndexes +
+        return "VisitedIndex{" +
+            "visitedIndexes=" + visitedIndexes +
             '}';
       }
 
       public void reset(int fieldsCount) {
-        this.vistedIndexes.clear(0, fieldsCount);
+        this.visitedIndexes.clear(0, fieldsCount);
       }
 
       public void markWritten(int i) {
-        vistedIndexes.set(i);
+        visitedIndexes.set(i);
       }
 
       public boolean isWritten(int i) {
-        return vistedIndexes.get(i);
+        return visitedIndexes.get(i);
       }
     }
 
     //track at each level of depth, which fields are written, so nulls can be 
inserted for the unwritten fields
     private final FieldsMarker[] fieldsWritten;
     private final int[] r;
-    private final ColumnWriter[] columnWriter;
+    private final ColumnWriter[] columnWriters;
 
     /**
      * Maintain a map of groups and all the leaf nodes underneath it. It's 
used to optimize writing null for a group node.
@@ -248,12 +248,12 @@ public class MessageColumnIO extends GroupColumnIO {
     public MessageColumnIORecordConsumer(ColumnWriteStore columns) {
       this.columns = columns;
       int maxDepth = 0;
-      this.columnWriter = new 
ColumnWriter[MessageColumnIO.this.getLeaves().size()];
+      this.columnWriters = new 
ColumnWriter[MessageColumnIO.this.getLeaves().size()];
 
       for (PrimitiveColumnIO primitiveColumnIO : 
MessageColumnIO.this.getLeaves()) {
         ColumnWriter w = 
columns.getColumnWriter(primitiveColumnIO.getColumnDescriptor());
         maxDepth = Math.max(maxDepth, primitiveColumnIO.getFieldPath().length);
-        columnWriter[primitiveColumnIO.getId()] = w;
+        columnWriters[primitiveColumnIO.getId()] = w;
         buildGroupToLeafWriterMap(primitiveColumnIO, w);
       }
 
@@ -351,7 +351,7 @@ public class MessageColumnIO extends GroupColumnIO {
 
     private void writeNull(ColumnIO undefinedField, int r, int d) {
       if (undefinedField.getType().isPrimitive()) {
-        columnWriter[((PrimitiveColumnIO) 
undefinedField).getId()].writeNull(r, d);
+        columnWriters[((PrimitiveColumnIO) 
undefinedField).getId()].writeNull(r, d);
       } else {
         GroupColumnIO groupColumnIO = (GroupColumnIO) undefinedField;
         // only cache the repetition level, the definition level should always 
be the definition level of the parent node
@@ -436,7 +436,7 @@ public class MessageColumnIO extends GroupColumnIO {
     }
 
     private ColumnWriter getColumnWriter() {
-      return columnWriter[((PrimitiveColumnIO) currentColumnIO).getId()];
+      return columnWriters[((PrimitiveColumnIO) currentColumnIO).getId()];
     }
 
     @Override