GitHub user VenturaDelMonte opened a pull request:
https://github.com/apache/flink/pull/2756
[FLINK-4997] Extending Window Function Metadata
This PR aims to introduce what discussed in
[FLIP-2](https://cwiki.apache.org/confluence/display/FLINK/FLIP-2+Extending+Window+Function+Metadata).
WindowedStream apply methods have been overloaded in order to support
ProcessWindowFunction (and its rich counterpart).
Streaming runtime internals have been modified in order to support the new
function, however fully backward compatibility to WindowFunction (and its rich
counterpart) is guaranteed by silently wrapping it with a ProcessWindowFunction.
This PR implementation strictly follow what decided in the FLIP, nothing
has been changed for AllWindowedStream.
Windows documentation has been overhauled in order to illustrate
ProcessWindowFunction API.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/VenturaDelMonte/flink flip-2
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/2756.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 #2756
----
commit 5a33fe2b9e5c23e8529964a489465f51410432df
Author: Ventura Del Monte <[email protected]>
Date: 2016-09-21T14:04:00Z
Merge remote-tracking branch 'apache/master'
commit 39a8bb9433edf5bb9adb850c667b71ef8d25c6b6
Author: Ventura Del Monte <[email protected]>
Date: 2016-09-22T08:31:58Z
Merge remote-tracking branch 'upstream/master'
commit 2507a71e2a40b05b3e5c7507a1c32d6678e07810
Author: Ventura Del Monte <[email protected]>
Date: 2016-09-22T09:40:40Z
Merge remote-tracking branch 'upstream/master'
commit 57d0bca5681e5ea0ba63f3b95fe4f949af3734de
Author: Ventura Del Monte <[email protected]>
Date: 2016-10-04T15:03:55Z
Merge remote-tracking branch 'upstream/master'
commit 9f55a1e3e56b48d9dc5a4d1b3109b41e1c89ce5d
Author: Ventura Del Monte <[email protected]>
Date: 2016-11-02T09:14:52Z
Merge remote-tracking branch 'upstream/master'
commit 9a71d092ad06c3592355ad11dfb7bd4b982ded9f
Author: Ventura Del Monte <[email protected]>
Date: 2016-11-03T20:44:56Z
[FLINK-4997] [streaming] Extending window function metadata introducing
ProcessWindowFunction
commit 878983074d364ea0d340bd3497343f286d28e3db
Author: Ventura Del Monte <[email protected]>
Date: 2016-11-04T14:29:52Z
[FLINK-4997] [docs] improved windows documentation explaining the new
ProcessWindowFunction API
----
---
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.
---
