apex-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] (APEXMALHAR-2006) Stream API Design
Date Tue, 17 May 2016 23:56:12 GMT

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

ASF GitHub Bot commented on APEXMALHAR-2006:
--------------------------------------------

Github user davidyan74 commented on a diff in the pull request:

    https://github.com/apache/incubator-apex-malhar/pull/261#discussion_r63624687
  
    --- Diff: library/src/main/java/com/datatorrent/lib/algo/UniqueCounter.java ---
    @@ -78,10 +78,10 @@ public void process(K tuple)
       /**
        * The output port which emits a map from keys to the number of times they occurred
within an application window.
        */
    -  public final transient DefaultOutputPort<HashMap<K, Integer>> count = new
DefaultOutputPort<HashMap<K, Integer>>()
    +  public final transient DefaultOutputPort<Map<K, Integer>> count = new DefaultOutputPort<Map<K,
Integer>>()
       {
         @Override
    -    public Unifier<HashMap<K, Integer>> getUnifier()
    --- End diff --
    
    should this change be in a separate commit?


> Stream API Design
> -----------------
>
>                 Key: APEXMALHAR-2006
>                 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2006
>             Project: Apache Apex Malhar
>          Issue Type: Sub-task
>            Reporter: Siyuan Hua
>            Assignee: Siyuan Hua
>             Fix For: 3.4.0
>
>
> Construct DAG in a similar way as Flink/Spark Streaming



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

Mime
View raw message