tdas commented on a change in pull request #33336:
URL: https://github.com/apache/spark/pull/33336#discussion_r669980571
##########
File path: sql/core/src/main/scala/org/apache/spark/sql/execution/objects.scala
##########
@@ -389,6 +389,102 @@ case class AppendColumnsWithObjectExec(
copy(child = newChild)
}
+/**
+ * Groups the input rows together and calls the function with each group and
an iterator containing
+ * all elements in the group. The result of this function is flattened before
being output. This
+ * version of the Physical operator takes a user provided initial state.
Review comment:
improve the docs as well. "This physical operator is similar to
MapGroupsExec but the difference that it calls the user-defined function with
.... group + iterator + user-defined initial state"
--
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]
