aboutsummaryrefslogtreecommitdiff
path: root/R
diff options
context:
space:
mode:
authorcafreeman <cfreeman@alteryx.com>2015-06-26 10:07:35 -0700
committerShivaram Venkataraman <shivaram@cs.berkeley.edu>2015-06-26 10:07:49 -0700
commita56516fc9280724db8fdef8e7d109ed7e28e427d (patch)
tree35474d160351c64409e31df98e48398b16fbb915 /R
parent41afa16500e682475eaa80e31c0434b7ab66abcb (diff)
downloadspark-a56516fc9280724db8fdef8e7d109ed7e28e427d.tar.gz
spark-a56516fc9280724db8fdef8e7d109ed7e28e427d.tar.bz2
spark-a56516fc9280724db8fdef8e7d109ed7e28e427d.zip
[SPARK-8662] SparkR Update SparkSQL Test
Test `infer_type` using a more fine-grained approach rather than comparing environments. Since `all.equal`'s behavior has changed in R 3.2, the test became unpassable. JIRA here: https://issues.apache.org/jira/browse/SPARK-8662 Author: cafreeman <cfreeman@alteryx.com> Closes #7045 from cafreeman/R32_Test and squashes the following commits: b97cc52 [cafreeman] Add `checkStructField` utility 3381e5c [cafreeman] Update SparkSQL Test (cherry picked from commit 78b31a2a630c2178987322d0221aeea183ec565f) Signed-off-by: Shivaram Venkataraman <shivaram@cs.berkeley.edu>
Diffstat (limited to 'R')
-rw-r--r--R/pkg/inst/tests/test_sparkSQL.R15
1 files changed, 12 insertions, 3 deletions
diff --git a/R/pkg/inst/tests/test_sparkSQL.R b/R/pkg/inst/tests/test_sparkSQL.R
index 417153dc09..6a08f89431 100644
--- a/R/pkg/inst/tests/test_sparkSQL.R
+++ b/R/pkg/inst/tests/test_sparkSQL.R
@@ -19,6 +19,14 @@ library(testthat)
context("SparkSQL functions")
+# Utility function for easily checking the values of a StructField
+checkStructField <- function(actual, expectedName, expectedType, expectedNullable) {
+ expect_equal(class(actual), "structField")
+ expect_equal(actual$name(), expectedName)
+ expect_equal(actual$dataType.toString(), expectedType)
+ expect_equal(actual$nullable(), expectedNullable)
+}
+
# Tests for SparkSQL functions in SparkR
sc <- sparkR.init()
@@ -52,9 +60,10 @@ test_that("infer types", {
list(type = 'array', elementType = "integer", containsNull = TRUE))
expect_equal(infer_type(list(1L, 2L)),
list(type = 'array', elementType = "integer", containsNull = TRUE))
- expect_equal(infer_type(list(a = 1L, b = "2")),
- structType(structField(x = "a", type = "integer", nullable = TRUE),
- structField(x = "b", type = "string", nullable = TRUE)))
+ testStruct <- infer_type(list(a = 1L, b = "2"))
+ expect_true(class(testStruct) == "structType")
+ checkStructField(testStruct$fields()[[1]], "a", "IntegerType", TRUE)
+ checkStructField(testStruct$fields()[[2]], "b", "StringType", TRUE)
e <- new.env()
assign("a", 1L, envir = e)
expect_equal(infer_type(e),