aboutsummaryrefslogtreecommitdiff
path: root/R/pkg/inst/tests/testthat/test_sparkSQL.R
diff options
context:
space:
mode:
authorFelix Cheung <felixcheung_m@hotmail.com>2017-01-24 00:23:23 -0800
committerFelix Cheung <felixcheung@apache.org>2017-01-24 00:23:23 -0800
commitf27e024768e328b96704a9ef35b77381da480328 (patch)
tree52ccff9438e4e8f41d1fe29e0707b2a493084a5a /R/pkg/inst/tests/testthat/test_sparkSQL.R
parentec9493b445cef512a3d64d6466ec7178cb01121f (diff)
downloadspark-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.R20
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)