diff options
| author | Narine Kokhlikyan <narine.kokhlikyan@gmail.com> | 2016-01-22 10:35:02 -0800 |
|---|---|---|
| committer | Shivaram Venkataraman <shivaram@cs.berkeley.edu> | 2016-01-22 10:35:02 -0800 |
| commit | 8a88e121283472c26e70563a4e04c109e9b183b3 (patch) | |
| tree | b2b1498caee3049c8315639b012a46155a0aa6fd /R/pkg/inst/tests | |
| parent | e13c147e74a52d74e259f04e49e368fab64cdc1f (diff) | |
| download | spark-8a88e121283472c26e70563a4e04c109e9b183b3.tar.gz spark-8a88e121283472c26e70563a4e04c109e9b183b3.tar.bz2 spark-8a88e121283472c26e70563a4e04c109e9b183b3.zip | |
[SPARK-12629][SPARKR] Fixes for DataFrame saveAsTable method
I've tried to solve some of the issues mentioned in: https://issues.apache.org/jira/browse/SPARK-12629
Please, let me know what do you think.
Thanks!
Author: Narine Kokhlikyan <narine.kokhlikyan@gmail.com>
Closes #10580 from NarineK/sparkrSavaAsRable.
Diffstat (limited to 'R/pkg/inst/tests')
| -rw-r--r-- | R/pkg/inst/tests/testthat/test_sparkSQL.R | 15 |
1 files changed, 14 insertions, 1 deletions
diff --git a/R/pkg/inst/tests/testthat/test_sparkSQL.R b/R/pkg/inst/tests/testthat/test_sparkSQL.R index e59841ab9f..b52a11fb1a 100644 --- a/R/pkg/inst/tests/testthat/test_sparkSQL.R +++ b/R/pkg/inst/tests/testthat/test_sparkSQL.R @@ -953,8 +953,21 @@ test_that("test HiveContext", { df3 <- sql(hiveCtx, "select * from json2") expect_is(df3, "DataFrame") expect_equal(count(df3), 3) - unlink(jsonPath2) + + hivetestDataPath <- tempfile(pattern="sparkr-test", fileext=".tmp") + invisible(saveAsTable(df, "hivetestbl", path = hivetestDataPath)) + df4 <- sql(hiveCtx, "select * from hivetestbl") + expect_is(df4, "DataFrame") + expect_equal(count(df4), 3) + unlink(hivetestDataPath) + + parquetDataPath <- tempfile(pattern="sparkr-test", fileext=".tmp") + invisible(saveAsTable(df, "parquetest", "parquet", mode="overwrite", path=parquetDataPath)) + df5 <- sql(hiveCtx, "select * from parquetest") + expect_is(df5, "DataFrame") + expect_equal(count(df5), 3) + unlink(parquetDataPath) }) test_that("column operators", { |