Class 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:
  • Constructor Details

    • TotalRankingsBolt

      public TotalRankingsBolt()
    • TotalRankingsBolt

      public TotalRankingsBolt(int topN)
    • TotalRankingsBolt

      public TotalRankingsBolt(int topN, int emitFrequencyInSeconds)