aboutsummaryrefslogtreecommitdiff
path: root/R/pkg/inst/tests/test_binaryFile.R
diff options
context:
space:
mode:
Diffstat (limited to 'R/pkg/inst/tests/test_binaryFile.R')
-rw-r--r--R/pkg/inst/tests/test_binaryFile.R7
1 files changed, 3 insertions, 4 deletions
diff --git a/R/pkg/inst/tests/test_binaryFile.R b/R/pkg/inst/tests/test_binaryFile.R
index ca4218f381..4db7266abc 100644
--- a/R/pkg/inst/tests/test_binaryFile.R
+++ b/R/pkg/inst/tests/test_binaryFile.R
@@ -59,15 +59,15 @@ test_that("saveAsObjectFile()/objectFile() following RDD transformations works",
wordCount <- lapply(words, function(word) { list(word, 1L) })
counts <- reduceByKey(wordCount, "+", 2L)
-
+
saveAsObjectFile(counts, fileName2)
counts <- objectFile(sc, fileName2)
-
+
output <- collect(counts)
expected <- list(list("awesome.", 1), list("Spark", 2), list("pretty.", 1),
list("is", 2))
expect_equal(sortKeyValueList(output), sortKeyValueList(expected))
-
+
unlink(fileName1)
unlink(fileName2, recursive = TRUE)
})
@@ -87,4 +87,3 @@ test_that("saveAsObjectFile()/objectFile() works with multiple paths", {
unlink(fileName1, recursive = TRUE)
unlink(fileName2, recursive = TRUE)
})
-