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 and 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

Methods inherited from class java.lang.Object

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

Constructor Detail

IntermediateRankingsBolt

public IntermediateRankingsBolt()

IntermediateRankingsBolt

public IntermediateRankingsBolt(int topN)

IntermediateRankingsBolt

public IntermediateRankingsBolt(int topN,
                                int emitFrequencyInSeconds)