flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-758) Add count method to DataSet and implement CountOperator
Date Mon, 16 Jun 2014 13:32:01 GMT

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

ASF GitHub Bot commented on FLINK-758:
--------------------------------------

Github user uce commented on the pull request:

    https://github.com/apache/incubator-flink/pull/20#issuecomment-46177838
  
    No, the idea was to provide it to the grouped one as well (I think I've enumerated all
reduce variants in the initial issue description). But I'm unsure if it makes much sense to
have an initial value per group. I guess that should be the discussion point. ;-)


> Add count method to DataSet and implement CountOperator
> -------------------------------------------------------
>
>                 Key: FLINK-758
>                 URL: https://issues.apache.org/jira/browse/FLINK-758
>             Project: Flink
>          Issue Type: Improvement
>            Reporter: GitHub Import
>              Labels: github-import
>             Fix For: pre-apache
>
>         Attachments: pull-request-758-7518001488867571817.patch
>
>
> At the request of @twalthr. This is the count operator I've implemented some time ago
to get the to know the new Java API. It introduces `DataSet.count()`, which is executed as
a map (to ones) and reduce (sum up the ones). I initially didn't do the PR, because of the
following problem: empty DataSets don't work as the first map won't have any input to operate
on.
> If more people think that we should include this operator we can think about a possible
solution to the problem.
> ---------------- Imported from GitHub ----------------
> Url: https://github.com/stratosphere/stratosphere/pull/758
> Created by: [uce|https://github.com/uce]
> Labels: enhancement, java api, 
> Milestone: Release 0.6 (unplanned)
> Created at: Tue May 06 10:42:33 CEST 2014
> State: open



--
This message was sent by Atlassian JIRA
(v6.2#6252)

Mime
View raw message