diff options
| author | Sun Rui <sunrui2016@gmail.com> | 2016-05-12 17:50:55 -0700 |
|---|---|---|
| committer | Shivaram Venkataraman <shivaram@cs.berkeley.edu> | 2016-05-12 17:50:55 -0700 |
| commit | b3930f74a0929b2cdcbbe5cbe34f0b1d35eb01cc (patch) | |
| tree | 6c08e7b8ca13d7e73f5c667b94bb6039211fd2bc /R/pkg/NAMESPACE | |
| parent | bb1362eb3b36b553dca246b95f59ba7fd8adcc8a (diff) | |
| download | spark-b3930f74a0929b2cdcbbe5cbe34f0b1d35eb01cc.tar.gz spark-b3930f74a0929b2cdcbbe5cbe34f0b1d35eb01cc.tar.bz2 spark-b3930f74a0929b2cdcbbe5cbe34f0b1d35eb01cc.zip | |
[SPARK-15202][SPARKR] add dapplyCollect() method for DataFrame in SparkR.
## What changes were proposed in this pull request?
dapplyCollect() applies an R function on each partition of a SparkDataFrame and collects the result back to R as a data.frame.
```
dapplyCollect(df, function(ldf) {...})
```
## How was this patch tested?
SparkR unit tests.
Author: Sun Rui <sunrui2016@gmail.com>
Closes #12989 from sun-rui/SPARK-15202.
Diffstat (limited to 'R/pkg/NAMESPACE')
| -rw-r--r-- | R/pkg/NAMESPACE | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/R/pkg/NAMESPACE b/R/pkg/NAMESPACE index 1432ab8a9d..239ad065d0 100644 --- a/R/pkg/NAMESPACE +++ b/R/pkg/NAMESPACE @@ -47,6 +47,7 @@ exportMethods("arrange", "covar_pop", "crosstab", "dapply", + "dapplyCollect", "describe", "dim", "distinct", |