This abstract bolt provides the basic behavior of bolts that rank objects according to their count.
This bolt ranks incoming objects by their count.
This bolt aggregates counts from multiple upstream bolts.
This bolt performs rolling counts of incoming objects, i.e.
Example of a simple custom bolt for joining two streams NOTE: Prefer to use the built-in JoinBolt wherever applicable
Computes sliding window sum
This bolt merges incoming
Copyright © 2017 The Apache Software Foundation. All Rights Reserved.