storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pubudu gunawardena <pubud...@gmail.com>
Subject A Question Regarding Storm Starter
Date Thu, 01 Oct 2015 10:14:41 GMT
Hi All,

I am using storm
starter(https://github.com/apache/storm/tree/master/examples/storm-starter)
as a base for implementing a trending count and have a small question
about the functionality. I will try to explain my question using an
example. Let's say that we are doing a trending word count and the
following happened.

For the first say, 10 seconds only the word "java' is emitted from the
spout. This will result in Java being ranked top in the top trending
count. Next, let's say that the spout stopped emitting the word "java"
and started to emit different words. This will remove the word java
from the respective intermediate ranking bolt(since it will rank other
words as top 5). In other words, the intermediate bolt won't emit the
information that the count for java went to zero.

It seems to me that due to this reason, the TotalRankingsBolt will
continue to keep the word java as the top ranked.

If this is the case there is a problem with the algorithm. Can someone
confirm this or point out to me if I'm wrong?

-- 
Thanks,
Pubudu

Mime
View raw message