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

Posted to issues@flink.apache.org by "Márton Balassi (JIRA)" <ji...@apache.org> on 2014/10/27 17:17:33 UTC

[jira] [Closed] (FLINK-1188) Streaming aggregations on array types

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

Márton Balassi closed FLINK-1188.
---------------------------------
       Resolution: Implemented
    Fix Version/s: 0.8-incubating

Resolved in the following commit:

https://git-wip-us.apache.org/repos/asf?p=incubator-flink.git;a=commit;h=7709a3a6906d015e82c8d3a3fce30a5a90da5167

> Streaming aggregations on array types
> -------------------------------------
>
>                 Key: FLINK-1188
>                 URL: https://issues.apache.org/jira/browse/FLINK-1188
>             Project: Flink
>          Issue Type: Improvement
>          Components: Streaming
>    Affects Versions: 0.8-incubating
>            Reporter: Márton Balassi
>            Assignee: Gyula Fora
>             Fix For: 0.8-incubating
>
>
> Currently aggregations work on fields of tuples, the goal of the issue is to extend this functionality to positions of arrays. One solution is to use an implementation of the KeySelector interface, however it would be a nice enhancement to have an API option for arrays, e.g. DataStream<int[]> intSream.min(0).



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