diff options
| author | Burak Yavuz <brkyvz@gmail.com> | 2016-04-05 17:21:41 -0700 |
|---|---|---|
| committer | Davies Liu <davies.liu@gmail.com> | 2016-04-05 17:21:41 -0700 |
| commit | 1146c534d6c3806f3e920043ba06838ef02cd7e8 (patch) | |
| tree | fa37966589999ea690cdfd71d18627e2ec234ed9 /R/pkg/NAMESPACE | |
| parent | 48682f6bf663e54cb63b7e95a4520d34b6fa890b (diff) | |
| download | spark-1146c534d6c3806f3e920043ba06838ef02cd7e8.tar.gz spark-1146c534d6c3806f3e920043ba06838ef02cd7e8.tar.bz2 spark-1146c534d6c3806f3e920043ba06838ef02cd7e8.zip | |
[SPARK-14353] Dataset Time Window `window` API for R
## What changes were proposed in this pull request?
The `window` function was added to Dataset with [this PR](https://github.com/apache/spark/pull/12008).
This PR adds the R API for this function.
With this PR, SQL, Java, and Scala will share the same APIs as in users can use:
- `window(timeColumn, windowDuration)`
- `window(timeColumn, windowDuration, slideDuration)`
- `window(timeColumn, windowDuration, slideDuration, startTime)`
In Python and R, users can access all APIs above, but in addition they can do
- In R:
`window(timeColumn, windowDuration, startTime=...)`
that is, they can provide the startTime without providing the `slideDuration`. In this case, we will generate tumbling windows.
## How was this patch tested?
Unit tests + manual tests
Author: Burak Yavuz <brkyvz@gmail.com>
Closes #12141 from brkyvz/R-windows.
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 fa3fb0b09a..f48c61c1d5 100644 --- a/R/pkg/NAMESPACE +++ b/R/pkg/NAMESPACE @@ -265,6 +265,7 @@ exportMethods("%in%", "var_samp", "weekofyear", "when", + "window", "year") exportClasses("GroupedData") |