You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/12 18:57:18 UTC

[jira] [Resolved] (FLINK-2991) Extend Window Operators to Allow Efficient Fold Operation

     [ https://issues.apache.org/jira/browse/FLINK-2991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Stephan Ewen resolved FLINK-2991.
---------------------------------
       Resolution: Fixed
    Fix Version/s: 1.0.0

Fixed via 94cba8998c726092e2cc80fd022ca40bf0c38ec2

> Extend Window Operators to Allow Efficient Fold Operation
> ---------------------------------------------------------
>
>                 Key: FLINK-2991
>                 URL: https://issues.apache.org/jira/browse/FLINK-2991
>             Project: Flink
>          Issue Type: Improvement
>          Components: Streaming
>            Reporter: Aljoscha Krettek
>            Assignee: Aljoscha Krettek
>             Fix For: 1.0.0
>
>
> Right now, a window fold is implemented as a WindowFunction that gets all the elements as input. No pre-aggregation is performed. The window operator should be extended to also allow the fold to also be pre-aggregated.
> This requires changing the signature of the {{WindowBuffer}} so that it can emit a type other than the input type. 



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)