GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/3207
Agg follow ups
Issues fixed in this PR:
- Add a `RichAggregateFunction`
- Document generic type parameters
- Document methods of the `AggregateFunction`
- Adds the `aggregate()` calls to `AllWindowStream`
- Allowing different input/output types for the cases where an additional
`WindowFunction` (or `AllWindowFunction`) is specified
- Adding the aggregate() methods to the Scala API
- Adding the window translation tests (Java/Scala Window/AllWindow)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/StephanEwen/incubator-flink agg_follow_ups
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3207.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 #3207
----
commit 4f9b6089808cac7007c0afe9ce1ce0b31d1fdee4
Author: Stephan Ewen <[email protected]>
Date: 2017-01-24T20:07:20Z
[hotfix] Make accidentally public 'aggregate()' method private
commit e624bf01fe6dce6e7679d20d50ba129ce7278cd5
Author: Stephan Ewen <[email protected]>
Date: 2017-01-24T19:08:28Z
[FLINK-5630] [streaming api] Followups to the AggregateFunction
- Add a RichAggregateFunction
- Document generic type parameters
- Allowing different input/output types for the cases where an additional
window apply function is specified
- Adding the aggregate() methods to the Scala API
- Adding the window translation tests
----
---
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.
---
