Github user ueshin commented on a diff in the pull request:
https://github.com/apache/spark/pull/22913#discussion_r230635196
--- Diff:
sql/core/src/main/java/org/apache/spark/sql/vectorized/ArrowColumnVector.java
---
@@ -414,6 +416,21 @@ final int getInt(int rowId) {
}
}
+ private static class DateMilliAccessor extends ArrowVectorAccessor {
+
+ private final DateMilliVector accessor;
+
+ DateMilliAccessor(DateMilliVector vector) {
+ super(vector);
+ this.accessor = vector;
+ }
+
+ @Override
+ final long getLong(int rowId) {
--- End diff --
We should use `getInt()` to represent the number of days from 1970-01-01 if
we map the type to date type.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
