Github user jiangxb1987 commented on a diff in the pull request:
https://github.com/apache/spark/pull/20277#discussion_r162531810
--- Diff:
sql/core/src/main/java/org/apache/spark/sql/vectorized/ColumnVector.java ---
@@ -152,19 +198,11 @@ public final ColumnarRow getStruct(int rowId) {
return new ColumnarRow(this, rowId);
}
- /**
- * A special version of {@link #getStruct(int)}, which is only used as
an adapter for Spark
- * codegen framework, the second parameter is totally ignored.
- */
- public final ColumnarRow getStruct(int rowId, int size) {
- return getStruct(rowId);
- }
-
/**
* Returns the array for rowId.
*/
public final ColumnarArray getArray(int rowId) {
- return new ColumnarArray(arrayData(), getArrayOffset(rowId),
getArrayLength(rowId));
+ return new ColumnarArray(getChild(0), getArrayOffset(rowId),
getArrayLength(rowId));
--- End diff --
Why change this?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
