aboutsummaryrefslogtreecommitdiff
path: root/R/pkg/inst/tests/test_sparkSQL.R
diff options
context:
space:
mode:
authorzero323 <matthew.szymkiewicz@gmail.com>2015-11-18 08:32:03 -0800
committerShivaram Venkataraman <shivaram@cs.berkeley.edu>2015-11-18 08:32:03 -0800
commita97d6f3a5861e9f2bbe36957e3b39f835f3e214c (patch)
treea43a499475991f193ebb70352ee6b6087d476af2 /R/pkg/inst/tests/test_sparkSQL.R
parent3a6807fdf07b0e73d76502a6bd91ad979fde8b61 (diff)
downloadspark-a97d6f3a5861e9f2bbe36957e3b39f835f3e214c.tar.gz
spark-a97d6f3a5861e9f2bbe36957e3b39f835f3e214c.tar.bz2
spark-a97d6f3a5861e9f2bbe36957e3b39f835f3e214c.zip
[SPARK-11281][SPARKR] Add tests covering the issue.
The goal of this PR is to add tests covering the issue to ensure that is was resolved by [SPARK-11086](https://issues.apache.org/jira/browse/SPARK-11086). Author: zero323 <matthew.szymkiewicz@gmail.com> Closes #9743 from zero323/SPARK-11281-tests.
Diffstat (limited to 'R/pkg/inst/tests/test_sparkSQL.R')
-rw-r--r--R/pkg/inst/tests/test_sparkSQL.R10
1 files changed, 7 insertions, 3 deletions
diff --git a/R/pkg/inst/tests/test_sparkSQL.R b/R/pkg/inst/tests/test_sparkSQL.R
index 8ff0627659..87ab33f638 100644
--- a/R/pkg/inst/tests/test_sparkSQL.R
+++ b/R/pkg/inst/tests/test_sparkSQL.R
@@ -229,7 +229,7 @@ test_that("create DataFrame from list or data.frame", {
df <- createDataFrame(sqlContext, l, c("a", "b"))
expect_equal(columns(df), c("a", "b"))
- l <- list(list(a=1, b=2), list(a=3, b=4))
+ l <- list(list(a = 1, b = 2), list(a = 3, b = 4))
df <- createDataFrame(sqlContext, l)
expect_equal(columns(df), c("a", "b"))
@@ -292,11 +292,15 @@ test_that("create DataFrame with complex types", {
})
test_that("create DataFrame from a data.frame with complex types", {
- ldf <- data.frame(row.names=1:2)
+ ldf <- data.frame(row.names = 1:2)
ldf$a_list <- list(list(1, 2), list(3, 4))
+ ldf$an_envir <- c(as.environment(list(a = 1, b = 2)), as.environment(list(c = 3)))
+
sdf <- createDataFrame(sqlContext, ldf)
+ collected <- collect(sdf)
- expect_equivalent(ldf, collect(sdf))
+ expect_identical(ldf[, 1, FALSE], collected[, 1, FALSE])
+ expect_equal(ldf$an_envir, collected$an_envir)
})
# For test map type and struct type in DataFrame