diff options
author | Felix Cheung <felixcheung_m@hotmail.com> | 2017-01-24 00:23:23 -0800 |
---|---|---|
committer | Felix Cheung <felixcheung@apache.org> | 2017-01-24 00:23:23 -0800 |
commit | f27e024768e328b96704a9ef35b77381da480328 (patch) | |
tree | 52ccff9438e4e8f41d1fe29e0707b2a493084a5a /R/pkg/inst/tests/testthat/test_sparkSQL.R | |
parent | ec9493b445cef512a3d64d6466ec7178cb01121f (diff) | |
download | spark-f27e024768e328b96704a9ef35b77381da480328.tar.gz spark-f27e024768e328b96704a9ef35b77381da480328.tar.bz2 spark-f27e024768e328b96704a9ef35b77381da480328.zip |
[SPARK-18823][SPARKR] add support for assigning to column
## What changes were proposed in this pull request?
Support for
```
df[[myname]] <- 1
df[[2]] <- df$eruptions
```
## How was this patch tested?
manual tests, unit tests
Author: Felix Cheung <felixcheung_m@hotmail.com>
Closes #16663 from felixcheung/rcolset.
Diffstat (limited to 'R/pkg/inst/tests/testthat/test_sparkSQL.R')
-rw-r--r-- | R/pkg/inst/tests/testthat/test_sparkSQL.R | 20 |
1 files changed, 20 insertions, 0 deletions
diff --git a/R/pkg/inst/tests/testthat/test_sparkSQL.R b/R/pkg/inst/tests/testthat/test_sparkSQL.R index 26017427ab..aaa8fb498c 100644 --- a/R/pkg/inst/tests/testthat/test_sparkSQL.R +++ b/R/pkg/inst/tests/testthat/test_sparkSQL.R @@ -1021,6 +1021,9 @@ test_that("select operators", { df$age2 <- df$age * 2 expect_equal(columns(df), c("name", "age", "age2")) expect_equal(count(where(df, df$age2 == df$age * 2)), 2) + df$age2 <- df[["age"]] * 3 + expect_equal(columns(df), c("name", "age", "age2")) + expect_equal(count(where(df, df$age2 == df$age * 3)), 2) df$age2 <- 21 expect_equal(columns(df), c("name", "age", "age2")) @@ -1033,6 +1036,23 @@ test_that("select operators", { expect_error(df$age3 <- c(22, NA), "value must be a Column, literal value as atomic in length of 1, or NULL") + df[["age2"]] <- 23 + expect_equal(columns(df), c("name", "age", "age2")) + expect_equal(count(where(df, df$age2 == 23)), 3) + + df[[3]] <- 24 + expect_equal(columns(df), c("name", "age", "age2")) + expect_equal(count(where(df, df$age2 == 24)), 3) + + df[[3]] <- df$age + expect_equal(count(where(df, df$age2 == df$age)), 2) + + df[["age2"]] <- df[["name"]] + expect_equal(count(where(df, df$age2 == df$name)), 3) + + expect_error(df[["age3"]] <- c(22, 23), + "value must be a Column, literal value as atomic in length of 1, or NULL") + # Test parameter drop expect_equal(class(df[, 1]) == "SparkDataFrame", T) expect_equal(class(df[, 1, drop = T]) == "Column", T) |