diff options
| author | adrian555 <wzhuang@us.ibm.com> | 2015-11-05 14:47:38 -0800 |
|---|---|---|
| committer | Shivaram Venkataraman <shivaram@cs.berkeley.edu> | 2015-11-05 14:47:38 -0800 |
| commit | b9455d1f1810e1e3f472014f665ad3ad3122bcc0 (patch) | |
| tree | d82b4ce2cbbe3833afcf77519a3470c5a5d98919 /R/pkg/inst/tests/test_sparkSQL.R | |
| parent | 8a5314efd19fb8f8a194a373fd994b954cc1fd47 (diff) | |
| download | spark-b9455d1f1810e1e3f472014f665ad3ad3122bcc0.tar.gz spark-b9455d1f1810e1e3f472014f665ad3ad3122bcc0.tar.bz2 spark-b9455d1f1810e1e3f472014f665ad3ad3122bcc0.zip | |
[SPARK-11260][SPARKR] with() function support
Author: adrian555 <wzhuang@us.ibm.com>
Author: Adrian Zhuang <adrian555@users.noreply.github.com>
Closes #9443 from adrian555/with.
Diffstat (limited to 'R/pkg/inst/tests/test_sparkSQL.R')
| -rw-r--r-- | R/pkg/inst/tests/test_sparkSQL.R | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/R/pkg/inst/tests/test_sparkSQL.R b/R/pkg/inst/tests/test_sparkSQL.R index b4a4d03b26..816315b1e4 100644 --- a/R/pkg/inst/tests/test_sparkSQL.R +++ b/R/pkg/inst/tests/test_sparkSQL.R @@ -1494,6 +1494,15 @@ test_that("attach() on a DataFrame", { expect_error(age) }) +test_that("with() on a DataFrame", { + df <- createDataFrame(sqlContext, iris) + expect_error(Sepal_Length) + sum1 <- with(df, list(summary(Sepal_Length), summary(Sepal_Width))) + expect_equal(collect(sum1[[1]])[1, "Sepal_Length"], "150") + sum2 <- with(df, distinct(Sepal_Length)) + expect_equal(nrow(sum2), 35) +}) + unlink(parquetPath) unlink(jsonPath) unlink(jsonPathNa) |