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).| Constructor and Description |
|---|
IntermediateRankingsBolt() |
IntermediateRankingsBolt(int topN) |
IntermediateRankingsBolt(int topN,
int emitFrequencyInSeconds) |
declareOutputFields, execute, getComponentConfiguration, getRankingscleanup, prepareCopyright © 2021 The Apache Software Foundation. All rights reserved.