[
https://issues.apache.org/jira/browse/APEXMALHAR-2006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15289437#comment-15289437
]
ASF GitHub Bot commented on APEXMALHAR-2006:
--------------------------------------------
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/261#discussion_r63750563
--- 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 stay here so I can use this in high-level API
> 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)
