You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/08 10:26:43 UTC
[jira] [Commented] (FLINK-4997) Extending Window Function Metadata
[ 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 <al...@gmail.com>
Date: 2017-02-07T09:54:54Z
[hotfix] Fix trailing whitespace in WindowedStream.java
commit ab74f4142ddc4aab6e76563b32464d526f719ae7
Author: Ventura Del Monte <ve...@gmail.com>
Date: 2016-11-23T17:00:23Z
[FLINK-4997] [streaming] Introduce ProcessWindowFunction
commit b6759f446bad5170fabc803103c764f204412301
Author: Ventura Del Monte <ve...@gmail.com>
Date: 2016-11-09T09:49:47Z
[FLINK-4997] [streaming] Add ProcessWindowFunction to Scala API
commit a9791e0e7526bfd419e72ac749ce068f18df857a
Author: Aljoscha Krettek <al...@gmail.com>
Date: 2017-02-07T13:38:25Z
[FLINK-4997] Add ProcessWindowFunction support for .aggregate()
commit 01048feccd5aced42b1979a3bf7b355443c08f5b
Author: Aljoscha Krettek <al...@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)