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 /external | |
| 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 'external')
0 files changed, 0 insertions, 0 deletions