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

public final class TotalRankingsBolt
extends AbstractRankerBolt

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:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TotalRankingsBolt()
TotalRankingsBolt(int topN)
TotalRankingsBolt(int topN, int emitFrequencyInSeconds)

Method Summary

Methods inherited from class org.apache.storm.starter.bolt.AbstractRankerBolt

declareOutputFields, execute, getComponentConfiguration, getRankings

Methods inherited from class org.apache.storm.topology.base.BaseBasicBolt

cleanup, prepare

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TotalRankingsBolt

public TotalRankingsBolt()

TotalRankingsBolt

public TotalRankingsBolt(int topN)

TotalRankingsBolt

public TotalRankingsBolt(int topN,
                         int emitFrequencyInSeconds)