Class | Description |
---|---|
AbstractRankerBolt |
This abstract bolt provides the basic behavior of bolts that rank objects according to their count.
|
IntermediateRankingsBolt |
This bolt ranks incoming objects by their count.
|
PrinterBolt | |
RollingCountAggBolt |
This bolt aggregates counts from multiple upstream bolts.
|
RollingCountBolt |
This bolt performs rolling counts of incoming objects, i.e.
|
SingleJoinBolt |
Example of a simple custom bolt for joining two streams NOTE: Prefer to use the built-in JoinBolt wherever applicable
|
SlidingWindowSumBolt |
Computes sliding window sum
|
TotalRankingsBolt |
This bolt merges incoming
Rankings . |
Copyright © 2019 The Apache Software Foundation. All rights reserved.