diff options
| author | Shivaram Venkataraman <shivaram@cs.berkeley.edu> | 2015-05-05 14:40:33 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2015-05-05 14:40:33 -0700 |
| commit | c688e3c5e46b26cb9fdba7987139c9ea63e2458b (patch) | |
| tree | 41fd5a477351567896187dc7791005ef112a74d7 /R/pkg/inst/worker/worker.R | |
| parent | 3059291e2027fb3ebbb2d3376610ce450f7c15a3 (diff) | |
| download | spark-c688e3c5e46b26cb9fdba7987139c9ea63e2458b.tar.gz spark-c688e3c5e46b26cb9fdba7987139c9ea63e2458b.tar.bz2 spark-c688e3c5e46b26cb9fdba7987139c9ea63e2458b.zip | |
[SPARK-7230] [SPARKR] Make RDD private in SparkR.
This change makes the RDD API private in SparkR and all internal uses of the SparkR API use SparkR::: to access private functions.
Author: Shivaram Venkataraman <shivaram@cs.berkeley.edu>
Closes #5895 from shivaram/rrdd-private and squashes the following commits:
bdb2f07 [Shivaram Venkataraman] Make RDD private in SparkR. This change also makes all internal uses of the SparkR API use SparkR::: to access private functions
Diffstat (limited to 'R/pkg/inst/worker/worker.R')
| -rw-r--r-- | R/pkg/inst/worker/worker.R | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/R/pkg/inst/worker/worker.R b/R/pkg/inst/worker/worker.R index 014bf7bd7b..7e3b5fc403 100644 --- a/R/pkg/inst/worker/worker.R +++ b/R/pkg/inst/worker/worker.R @@ -72,7 +72,7 @@ if (numBroadcastVars > 0) { for (bcast in seq(1:numBroadcastVars)) { bcastId <- SparkR:::readInt(inputCon) value <- unserialize(SparkR:::readRaw(inputCon)) - setBroadcastValue(bcastId, value) + SparkR:::setBroadcastValue(bcastId, value) } } |