LuciferYang commented on a change in pull request #34659:
URL: https://github.com/apache/spark/pull/34659#discussion_r840992415
##########
File path:
sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/WritableColumnVector.java
##########
@@ -714,15 +718,47 @@ public WritableColumnVector arrayData() {
public WritableColumnVector getChild(int ordinal) { return
childColumns[ordinal]; }
/**
- * Returns the elements appended.
+ * Returns the number of child vectors.
+ */
+ public int getNumChildren() {
+ return childColumns.length;
+ }
+
+ /**
+ * Returns the elements appended. This is useful
*/
public final int getElementsAppended() { return elementsAppended; }
+ /**
+ * Increment number of elements appended by 'num'.
+ *
+ * This is useful when one wants to use the 'putXXX' API to add new elements
to the vector, but
+ * still want to keep count of how many elements have been added (since the
'putXXX' APIs don't
+ * increment count).
+ */
+ public final void addElementsAppended(int num) {
+ elementsAppended += num;
+ }
+
/**
* Marks this column as being constant.
*/
public final void setIsConstant() { isConstant = true; }
+ /**
+ * Marks this column only contains null values.
+ */
+ public final void setAllNull() {
Review comment:
OK, let's ignore this for the time being
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
