GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/1765
[FLINK-3578] Support RichFunctions for Scala Window Function and
AllWindowFunction
This adds support RichFunctions for Scala Window Function and
AllWindowFunction.
RichFunction method calls (`open()`, `close()`, `RuntimeContext`) are
properly forwarded.
This also consolidates the various wrapper classes for fold() and reduce()
functions.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/StephanEwen/incubator-flink scala_rich
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/1765.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 #1765
----
commit 7893456c00b37ecdb11d701980700e880636c9fb
Author: Stephan Ewen <[email protected]>
Date: 2016-03-04T11:23:45Z
[FLINK-3578] [streaming scala] Support RichFunctions for Scala
WindowFunction and AllWindowFunction
This also consolidates the various wrapper classes for fold() and reduce()
functions.
----
---
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.
---
