Package org.apache.storm.starter.bolt
Class TotalRankingsBolt
java.lang.Object
org.apache.storm.topology.base.BaseComponent
org.apache.storm.topology.base.BaseBasicBolt
org.apache.storm.starter.bolt.AbstractRankerBolt
org.apache.storm.starter.bolt.TotalRankingsBolt
- All Implemented Interfaces:
Serializable,IBasicBolt,IComponent
This bolt merges incoming
Rankings.
It can be used to merge intermediate rankings generated by IntermediateRankingsBolt into a final,
consolidated ranking. To do so, configure this bolt with a globalGrouping on IntermediateRankingsBolt.- See Also:
-
Constructor Summary
ConstructorsConstructorDescriptionTotalRankingsBolt(int topN) TotalRankingsBolt(int topN, int emitFrequencyInSeconds) -
Method Summary
Methods inherited from class org.apache.storm.starter.bolt.AbstractRankerBolt
declareOutputFields, execute, getComponentConfiguration, getRankingsMethods inherited from class org.apache.storm.topology.base.BaseBasicBolt
cleanup, prepare
-
Constructor Details
-
TotalRankingsBolt
public TotalRankingsBolt() -
TotalRankingsBolt
public TotalRankingsBolt(int topN) -
TotalRankingsBolt
public TotalRankingsBolt(int topN, int emitFrequencyInSeconds)
-