From ce072ebf125ead8f2145146c9a685899d6e436d7 Mon Sep 17 00:00:00 2001 From: Josh Soref Date: Tue, 8 Dec 2020 20:32:07 -0500 Subject: [PATCH] spelling: binaries Signed-off-by: Josh Soref --- .../execution/datasources/parquet/VectorizedColumnReader.java | 2 +- .../datasources/parquet/VectorizedRleValuesReader.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedColumnReader.java b/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedColumnReader.java index 1b8b18d4d8735..4b2c9325941c8 100644 --- a/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedColumnReader.java +++ b/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedColumnReader.java @@ -615,7 +615,7 @@ private void readBinaryBatch(int rowId, int num, WritableColumnVector column) th VectorizedValuesReader data = (VectorizedValuesReader) dataColumn; if (column.dataType() == DataTypes.StringType || column.dataType() == DataTypes.BinaryType || DecimalType.isByteArrayDecimalType(column.dataType())) { - defColumn.readBinarys(num, column, rowId, maxDefLevel, data); + defColumn.readBinaries(num, column, rowId, maxDefLevel, data); } else if (column.dataType() == DataTypes.TimestampType) { final boolean failIfRebase = "EXCEPTION".equals(int96RebaseMode); if (!shouldConvertTimestamps()) { diff --git a/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedRleValuesReader.java b/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedRleValuesReader.java index 03595068f0d31..d6600206d66d2 100644 --- a/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedRleValuesReader.java +++ b/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedRleValuesReader.java @@ -486,7 +486,7 @@ public void readDoubles( } } - public void readBinarys( + public void readBinaries( int total, WritableColumnVector c, int rowId,