minor

sameeragarwal · Mar 18, 2016 · 93f2cef · 93f2cef
1 parent 3271ada
commit 93f2cef
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ava/org/apache/spark/sql/execution/datasources/parquet/VectorizedParquetRecordReader.java b/...ava/org/apache/spark/sql/execution/datasources/parquet/VectorizedParquetRecordReader.java
@@ -553,7 +553,7 @@ private void readIntBatch(int rowId, int num, ColumnVector column) throws IOExce
       // This is where we implement support for the valid type conversions.
       // TODO: implement remaining type conversions
       if (column.dataType() == DataTypes.IntegerType || column.dataType() == DataTypes.DateType ||
-          DecimalType.is32BitDecimalType(column.dataType())) {
+        DecimalType.is32BitDecimalType(column.dataType())) {
         defColumn.readIntegers(
             num, column, rowId, maxDefLevel, (VectorizedValuesReader) dataColumn);
       } else if (column.dataType() == DataTypes.ByteType) {
@@ -620,7 +620,7 @@ private void readFixedLenByteArrayBatch(int rowId, int num,
         for (int i = 0; i < num; i++) {
           if (defColumn.readInteger() == maxDefLevel) {
             column.putInt(rowId + i,
-                (int) CatalystRowConverter.binaryToUnscaledLong(data.readBinary(arrayLen)));
+              (int) CatalystRowConverter.binaryToUnscaledLong(data.readBinary(arrayLen)));
           } else {
             column.putNull(rowId + i);
           }