[
https://issues.apache.org/jira/browse/FLINK-3899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420125#comment-15420125
]
ASF GitHub Bot commented on FLINK-3899:
---------------------------------------
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
----
> Document window processing with Reduce/FoldFunction + WindowFunction
> --------------------------------------------------------------------
>
> Key: FLINK-3899
> URL: https://issues.apache.org/jira/browse/FLINK-3899
> Project: Flink
> Issue Type: Improvement
> Components: Documentation, Streaming
> Affects Versions: 1.1.0
> Reporter: Fabian Hueske
>
> The streaming documentation does not describe how windows can be processed
> with FoldFunction or ReduceFunction and a subsequent WindowFunction. This
> combination allows for eager window aggregation (only a single element is
> kept in the window) and access of the Window object, e.g., to have access to
> the window's start and end time.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
