diff options
| author | felixcheung <felixcheung_m@hotmail.com> | 2016-01-04 22:32:07 -0800 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2016-01-04 22:32:07 -0800 |
| commit | cc4d5229c98a589da76a4d5e5fdc5ea92385183b (patch) | |
| tree | 450ee4286632f96c991d0cfd9b67f1509529c68f /R/pkg/inst/tests/testthat/test_sparkSQL.R | |
| parent | b634901bb28070ac5d9a24a9bc7b7640472a54e2 (diff) | |
| download | spark-cc4d5229c98a589da76a4d5e5fdc5ea92385183b.tar.gz spark-cc4d5229c98a589da76a4d5e5fdc5ea92385183b.tar.bz2 spark-cc4d5229c98a589da76a4d5e5fdc5ea92385183b.zip | |
[SPARK-12625][SPARKR][SQL] replace R usage of Spark SQL deprecated API
rxin davies shivaram
Took save mode from my PR #10480, and move everything to writer methods. This is related to PR #10559
- [x] it seems jsonRDD() is broken, need to investigate - this is not a public API though; will look into some more tonight. (fixed)
Author: felixcheung <felixcheung_m@hotmail.com>
Closes #10584 from felixcheung/rremovedeprecated.
Diffstat (limited to 'R/pkg/inst/tests/testthat/test_sparkSQL.R')
| -rw-r--r-- | R/pkg/inst/tests/testthat/test_sparkSQL.R | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/R/pkg/inst/tests/testthat/test_sparkSQL.R b/R/pkg/inst/tests/testthat/test_sparkSQL.R index 9e5d0ebf60..ebe8faa34c 100644 --- a/R/pkg/inst/tests/testthat/test_sparkSQL.R +++ b/R/pkg/inst/tests/testthat/test_sparkSQL.R @@ -423,12 +423,12 @@ test_that("read/write json files", { test_that("jsonRDD() on a RDD with json string", { rdd <- parallelize(sc, mockLines) expect_equal(count(rdd), 3) - df <- jsonRDD(sqlContext, rdd) + df <- suppressWarnings(jsonRDD(sqlContext, rdd)) expect_is(df, "DataFrame") expect_equal(count(df), 3) rdd2 <- flatMap(rdd, function(x) c(x, x)) - df <- jsonRDD(sqlContext, rdd2) + df <- suppressWarnings(jsonRDD(sqlContext, rdd2)) expect_is(df, "DataFrame") expect_equal(count(df), 6) }) |