Package org.apache.storm.starter.bolt
Class IntermediateRankingsBolt
- 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.IntermediateRankingsBolt
-
- All Implemented Interfaces:
Serializable
,IBasicBolt
,IComponent
public final class IntermediateRankingsBolt extends AbstractRankerBolt
This bolt ranks incoming objects by their count. It assumes the input tuples to adhere to the following format: (object, object_count, additionalField1, additionalField2, ..., additionalFieldN).- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description IntermediateRankingsBolt()
IntermediateRankingsBolt(int topN)
IntermediateRankingsBolt(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
-
-