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
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:
-
Constructor Summary
ConstructorDescriptionIntermediateRankingsBolt
(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
-
Constructor Details
-
IntermediateRankingsBolt
public IntermediateRankingsBolt() -
IntermediateRankingsBolt
public IntermediateRankingsBolt(int topN) -
IntermediateRankingsBolt
public IntermediateRankingsBolt(int topN, int emitFrequencyInSeconds)
-