flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Stephan Ewen (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-1023) Provide Iterable instead of Iterator to grouped functions
Date Wed, 23 Jul 2014 10:34:38 GMT

    [ https://issues.apache.org/jira/browse/FLINK-1023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14071580#comment-14071580

Stephan Ewen commented on FLINK-1023:

Does it make sense to have a rich object, like {{Sequence}} or so? It could implement, {{Iterator}},
{{Iterable}}, plus methods like {{materialize()}} so you could go through the sequence multiple

It may be a bit redundant, though. Scala has tools for that already (for example to materialize

> Provide Iterable instead of Iterator to grouped functions
> ---------------------------------------------------------
>                 Key: FLINK-1023
>                 URL: https://issues.apache.org/jira/browse/FLINK-1023
>             Project: Flink
>          Issue Type: Wish
>          Components: Java API
>            Reporter: Ufuk Celebi
>            Priority: Trivial
>              Labels: breaking-api
> I would like the grouped functions to provide an Iterable instead of an Iterator to the
user, e.g. for the {{reduce}} method of {{GroupReduceFunction}}.
> We had a discussion about this previously (I couldn't find the respective issues/list
threads right now) and the result was in favor of the change.
> We never got around to really push for it, because of the API break. With the renaming,
it should be less of an issue.

This message was sent by Atlassian JIRA

View raw message