Github user gatorsmile commented on a diff in the pull request:
https://github.com/apache/spark/pull/19702#discussion_r150378160
--- Diff:
sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedColumnReader.java
---
@@ -91,11 +92,13 @@
private final PageReader pageReader;
private final ColumnDescriptor descriptor;
+ private final OriginalType originalType;
- public VectorizedColumnReader(ColumnDescriptor descriptor, PageReader
pageReader)
+ public VectorizedColumnReader(ColumnDescriptor descriptor, OriginalType
t, PageReader pageReader)
--- End diff --
`t` -> `originalType` or `logicalType`
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
