Github user srowen commented on a diff in the pull request:
https://github.com/apache/spark/pull/21975#discussion_r207542543
--- Diff:
sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedColumnReader.java
---
@@ -195,7 +197,7 @@ void readBatch(int total, WritableColumnVector column)
throws IOException {
decodeDictionaryIds(0, rowId, column, column.getDictionaryIds());
}
column.setDictionary(null);
- switch (descriptor.getType()) {
+ switch (descriptor.getPrimitiveType().getPrimitiveTypeName()) {
--- End diff --
Can you use `typeName` here too?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
