Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/19436#discussion_r142901810
--- Diff: R/pkg/tests/fulltests/test_sparkSQL.R ---
@@ -3075,6 +3075,11 @@ test_that("gapply() and gapplyCollect() on a
DataFrame", {
df1Collect <- gapplyCollect(df, list("a"), function(key, x) { x })
expect_identical(df1Collect, expected)
+ # gapply on empty grouping columns.
+ dfTwoPartition <- repartition(df, 2L)
+ df1TwoPartition <- gapply(dfTwoPartition, c(), function(key, x) { x },
schema(dfTwoPartition))
+ expect_identical(sort(collect(df1TwoPartition)), sort(expected))
--- End diff --
Actually, I tested these:
```R
df1 <- gapply(df, c(), function(key, x) { x }, schema(df))
actual <- collect(df1)
expect_identical(actual, expected)
```
---
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
