diff options
| author | Davies Liu <davies.liu@gmail.com> | 2016-03-28 10:21:02 -0700 |
|---|---|---|
| committer | Davies Liu <davies.liu@gmail.com> | 2016-03-28 10:21:02 -0700 |
| commit | e5a1b301fbe191f1a9627a1083d960c98f543d13 (patch) | |
| tree | 3c1ee9e3d56e7c8e41c54b70a6bf8472c0078d54 /R | |
| parent | 40984f67065eeaea731940008e6677c2323dda3e (diff) | |
| download | spark-e5a1b301fbe191f1a9627a1083d960c98f543d13.tar.gz spark-e5a1b301fbe191f1a9627a1083d960c98f543d13.tar.bz2 spark-e5a1b301fbe191f1a9627a1083d960c98f543d13.zip | |
Revert "[SPARK-12792] [SPARKR] Refactor RRDD to support R UDF."
This reverts commit 40984f67065eeaea731940008e6677c2323dda3e.
Diffstat (limited to 'R')
| -rw-r--r-- | R/pkg/inst/tests/testthat/test_rdd.R | 8 |
1 files changed, 0 insertions, 8 deletions
diff --git a/R/pkg/inst/tests/testthat/test_rdd.R b/R/pkg/inst/tests/testthat/test_rdd.R index b6c8e1dc6c..3b0c16be5a 100644 --- a/R/pkg/inst/tests/testthat/test_rdd.R +++ b/R/pkg/inst/tests/testthat/test_rdd.R @@ -791,11 +791,3 @@ test_that("sampleByKey() on pairwise RDDs", { expect_equal(lookup(sample, 3)[which.min(lookup(sample, 3))] >= 0, TRUE) expect_equal(lookup(sample, 3)[which.max(lookup(sample, 3))] <= 2000, TRUE) }) - -test_that("Test correct concurrency of RRDD.compute()", { - rdd <- parallelize(sc, 1:1000, 100) - jrdd <- getJRDD(lapply(rdd, function(x) { x }), "row") - zrdd <- callJMethod(jrdd, "zip", jrdd) - count <- callJMethod(zrdd, "count") - expect_equal(count, 1000) -}) |