Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/19872#discussion_r154642902
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/pythonLogicalOperators.scala
---
@@ -38,3 +38,13 @@ case class FlatMapGroupsInPandas(
*/
override val producedAttributes = AttributeSet(output)
}
+
+case class AggregateInPandas(
+ groupingAttributes: Seq[Attribute],
+ functionExprs: Seq[Expression],
+ output: Seq[Attribute],
+ child: LogicalPlan
+) extends UnaryNode {
--- End diff --
nit:
```
child: LogicalPlan) extends UnaryNode {
```
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
