[ https://issues.apache.org/jira/browse/FLINK-4997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15857801#comment-15857801 ]
ASF GitHub Bot commented on FLINK-4997: --------------------------------------- GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/3285 [FLINK-4997] [streaming] Introduce ProcessWindowFunction This is an updated/enhanced version of #2756. I did roughly these changes: - Add support for the `AggregatingFunction`/`ProcessWindowFunction` combination - Mark the new methods/interfaces as `@PublicEvolving` - Change how the Scala wrapper functions work because we recently moved all of them to use `WrappingFunction`. This is not complete yet and I created issues for fixing that: https://issues.apache.org/jira/browse/FLINK-5740 and https://issues.apache.org/jira/browse/FLINK-5741 - Add tests in `WindowTranslationTest.java` and `WindowTranslationTest.scala`. @VenturaDelMonte and @manuzhang, would you like to have a look at this. I took quite a while because there was some upheaval in the internals of that part of the code and the tests. I'm sorry for that. You can merge this pull request into a Git repository by running: $ git pull https://github.com/aljoscha/flink process-window-function Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/3285.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 #3285 ---- commit 6f476f92f22b661f26d322615af6a52eca01c69c Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Date: 2017-02-07T09:54:54Z [hotfix] Fix trailing whitespace in WindowedStream.java commit ab74f4142ddc4aab6e76563b32464d526f719ae7 Author: Ventura Del Monte <venturadelmo...@gmail.com> Date: 2016-11-23T17:00:23Z [FLINK-4997] [streaming] Introduce ProcessWindowFunction commit b6759f446bad5170fabc803103c764f204412301 Author: Ventura Del Monte <venturadelmo...@gmail.com> Date: 2016-11-09T09:49:47Z [FLINK-4997] [streaming] Add ProcessWindowFunction to Scala API commit a9791e0e7526bfd419e72ac749ce068f18df857a Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Date: 2017-02-07T13:38:25Z [FLINK-4997] Add ProcessWindowFunction support for .aggregate() commit 01048feccd5aced42b1979a3bf7b355443c08f5b Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Date: 2016-11-24T07:14:48Z [FLINK-5237] Consolidate and harmonize Window Translation Tests ---- > Extending Window Function Metadata > ---------------------------------- > > Key: FLINK-4997 > URL: https://issues.apache.org/jira/browse/FLINK-4997 > Project: Flink > Issue Type: New Feature > Components: DataStream API, Streaming > Reporter: Ventura Del Monte > Assignee: Ventura Del Monte > > https://cwiki.apache.org/confluence/display/FLINK/FLIP-2+Extending+Window+Function+Metadata -- This message was sent by Atlassian JIRA (v6.3.15#6346)