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 <se...@apache.org> Date: 2017-01-24T20:07:20Z [hotfix] Make accidentally public 'aggregate()' method private commit e624bf01fe6dce6e7679d20d50ba129ce7278cd5 Author: Stephan Ewen <se...@apache.org> 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 infrastruct...@apache.org or file a JIRA ticket with INFRA. ---