Github user icexelloss commented on a diff in the pull request:
https://github.com/apache/spark/pull/18732#discussion_r143507748
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/object.scala
---
@@ -519,3 +519,18 @@ case class CoGroup(
outputObjAttr: Attribute,
left: LogicalPlan,
right: LogicalPlan) extends BinaryNode with ObjectProducer
+
+case class FlatMapGroupsInPandas(
--- End diff --
@HyukjinKwon Thanks for catching this. I added docs for
`FlatMapGroupsInPandas` (function) `FlatMapGroupsInPandas` (logical node) and
`FlatMapGroupsInPandasExec` and cross referenced them.
@rxin I created file `pythonLogicalOperators` under
`org.apache.spark.sql.catalyst.plans.logical` and move `FlatMapGroupsInPandas`
under that file.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
