public final class TotalRankingsBolt extends AbstractRankerBolt
This bolt merges incoming Rankings.
IntermediateRankingsBolt into a final, consolidated ranking. To do so, configure this bolt with a globalGrouping on IntermediateRankingsBolt.| Constructor and Description |
|---|
TotalRankingsBolt() |
TotalRankingsBolt(int topN) |
TotalRankingsBolt(int topN,
int emitFrequencyInSeconds) |
declareOutputFields, execute, getComponentConfiguration, getRankingscleanup, prepareCopyright © 2021 The Apache Software Foundation. All rights reserved.