storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ptgo...@apache.org
Subject [27/50] [abbrv] git commit: TotalRankingsBolt: prune zero count rankings after each emit
Date Thu, 20 Mar 2014 21:22:50 GMT
TotalRankingsBolt: prune zero count rankings after each emit


Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/d596aaf2
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/d596aaf2
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/d596aaf2

Branch: refs/heads/master
Commit: d596aaf2c14064a39865c177aea9bbeca20d2493
Parents: fa424ae
Author: Michael G. Noll <mnoll@verisign.com>
Authored: Thu Aug 29 12:55:09 2013 +0200
Committer: Michael G. Noll <mnoll@verisign.com>
Committed: Thu Aug 29 12:55:09 2013 +0200

----------------------------------------------------------------------
 src/jvm/storm/starter/bolt/TotalRankingsBolt.java | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/d596aaf2/src/jvm/storm/starter/bolt/TotalRankingsBolt.java
----------------------------------------------------------------------
diff --git a/src/jvm/storm/starter/bolt/TotalRankingsBolt.java b/src/jvm/storm/starter/bolt/TotalRankingsBolt.java
index 846ff49..217443e 100644
--- a/src/jvm/storm/starter/bolt/TotalRankingsBolt.java
+++ b/src/jvm/storm/starter/bolt/TotalRankingsBolt.java
@@ -31,6 +31,7 @@ public final class TotalRankingsBolt extends AbstractRankerBolt {
   void updateRankingsWithTuple(Tuple tuple) {
     Rankings rankingsToBeMerged = (Rankings) tuple.getValue(0);
     super.getRankings().updateWith(rankingsToBeMerged);
+    super.getRankings().pruneZeroCounts();
   }
 
   @Override


Mime
View raw message