Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/20471#discussion_r165288359
--- Diff:
sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/MutableColumnarRow.java
---
@@ -162,8 +162,9 @@ public ColumnarArray getArray(int ordinal) {
}
@Override
- public MapData getMap(int ordinal) {
- throw new UnsupportedOperationException();
+ public ColumnarMap getMap(int ordinal) {
+ if (columns[ordinal].isNullAt(rowId)) return null;
--- End diff --
I will remove this null check in #20455 later after this gets merged.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
