GitHub user danielblazevski opened a pull request:
https://github.com/apache/flink/pull/2368
[FLINK-3899] Document window processing with Reduce/FoldFunction +
WindowFunction
Added example of using Reduce/Fold + Window in docs. The examples were
tested to run -- I used the sensor reading class from dataArtisans/blogposts.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/danielblazevski/flink FLINK-3899
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/2368.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #2368
----
commit 3b7466b161eecfdb7b862dafce0ed4fac2248ecd
Author: danielblazevski <[email protected]>
Date: 2016-08-13T22:57:18Z
added example of fold/window and reduce/window
commit 9dfc44f2867ca1d5f92beb625f264c0d92632784
Author: danielblazevski <[email protected]>
Date: 2016-08-13T22:58:19Z
added example of fold/window and reduce/window
commit 44553dbfc97e04e3f36eaec9a2e24a08e886e26f
Author: danielblazevski <[email protected]>
Date: 2016-08-13T23:07:29Z
removed throws exception
commit c121b51a08a0d4c73eb703fa68e17b90b8d5fc17
Author: danielblazevski <[email protected]>
Date: 2016-08-13T23:11:30Z
changed String var to in window fns
commit 747e989001651a31194a9d6f3071f57518c0c03c
Author: danielblazevski <[email protected]>
Date: 2016-08-13T23:14:48Z
changed start time to end time typo
commit 9669866440b55740eecc16250b6cfb48636e7ad7
Author: danielblazevski <[email protected]>
Date: 2016-08-13T23:16:29Z
changed to typo
commit d72eb69806f89b9089731edbb8c7d7d630e4877e
Author: danielblazevski <[email protected]>
Date: 2016-08-13T23:41:09Z
added scala example
commit a8ccb49928edf9b0b37acb67439519f82e412988
Author: danielblazevski <[email protected]>
Date: 2016-08-13T23:46:19Z
format: added empty line after each class def for java
commit 071b706f0b9d52d4232c20f68a87aa5514a0a40d
Author: danielblazevski <[email protected]>
Date: 2016-08-13T23:49:02Z
changed names of iterable inputs
commit a55305f9b57d812b81b6cd6849b658f5c17344f8
Author: danielblazevski <[email protected]>
Date: 2016-08-13T23:50:53Z
changed MIN_VALUE to MinValue for Scala
commit d404568663d375acfa2e9e48b79f775f4e2bb37c
Author: danielblazevski <[email protected]>
Date: 2016-08-13T23:52:41Z
removed semicolon in Scala example
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
