TotalRankingsBolt (Storm 2.7.1 API)

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