diff --git a/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedReaderBase.java b/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedReaderBase.java index ab8fd9bdb6ff0..77bb9340e5263 100644 --- a/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedReaderBase.java +++ b/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedReaderBase.java @@ -109,6 +109,16 @@ public void readBinary(int total, WritableColumnVector c, int rowId) { throw SparkUnsupportedOperationException.apply(); } + @Override + public void readGeometry(int total, WritableColumnVector c, int rowId) { + throw SparkUnsupportedOperationException.apply(); + } + + @Override + public void readGeography(int total, WritableColumnVector c, int rowId) { + throw SparkUnsupportedOperationException.apply(); + } + @Override public void skipBooleans(int total) { throw SparkUnsupportedOperationException.apply(); diff --git a/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedValuesReader.java b/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedValuesReader.java index 4308614338499..d29ce0dd12e4c 100644 --- a/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedValuesReader.java +++ b/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedValuesReader.java @@ -57,6 +57,8 @@ void readLongsWithRebase( void readFloats(int total, WritableColumnVector c, int rowId); void readDoubles(int total, WritableColumnVector c, int rowId); void readBinary(int total, WritableColumnVector c, int rowId); + void readGeometry(int total, WritableColumnVector c, int rowId); + void readGeography(int total, WritableColumnVector c, int rowId); /* * Skips `total` values