Github user kiszk commented on a diff in the pull request:
https://github.com/apache/spark/pull/19970#discussion_r156874906
--- Diff:
sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/WritableColumnVector.java
---
@@ -105,6 +107,57 @@ private void throwUnsupportedException(int
requiredCapacity, Throwable cause) {
@Override
public boolean anyNullsSet() { return anyNullsSet; }
+ /**
+ * Returns the dictionary Id for rowId.
+ * This should only be called when the ColumnVector is dictionaryIds.
--- End diff --
`ColumnVector` -> `WritableColumnVector`
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
