Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/21939#discussion_r206731172
--- Diff:
sql/core/src/main/java/org/apache/spark/sql/vectorized/ArrowColumnVector.java
---
@@ -162,13 +162,13 @@ public ArrowColumnVector(ValueVector vector) {
} else if (vector instanceof ListVector) {
ListVector listVector = (ListVector) vector;
accessor = new ArrayAccessor(listVector);
- } else if (vector instanceof NullableMapVector) {
- NullableMapVector mapVector = (NullableMapVector) vector;
- accessor = new StructAccessor(mapVector);
+ } else if (vector instanceof StructVector) {
+ StructVector structVector = (StructVector) vector;
--- End diff --
two spaces here :-) `= (` -> `= (`.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
