From 0f2d0e8d0df9db6361b7037c735030879392be61 Mon Sep 17 00:00:00 2001
From: brightchen <bright@datatorrent.com>
Date: Wed, 16 Nov 2016 11:29:46 -0800
Subject: [PATCH] APEXMALHAR-2343 #resolve #comment Count Accumulation should
 only increase one for each tuple

---
 .../apache/apex/malhar/lib/window/accumulation/Count.java   | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/Count.java b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/Count.java
index 62c5678ac7..dbc9f0f398 100644
--- a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/Count.java
+++ b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/Count.java
@@ -26,7 +26,7 @@
  *
  * @since 3.5.0
  */
-public class Count implements Accumulation<Long, MutableLong, Long>
+public class Count implements Accumulation<Object, MutableLong, Long>
 {
 
   @Override
@@ -36,9 +36,9 @@ public MutableLong defaultAccumulatedValue()
   }
 
   @Override
-  public MutableLong accumulate(MutableLong accumulatedValue, Long input)
+  public MutableLong accumulate(MutableLong accumulatedValue, Object input)
   {
-    accumulatedValue.add(input);
+    accumulatedValue.increment();
     return accumulatedValue;
   }