Hi Daniela,
For storm core, windowed bolts would give you the tuples in the last minute but
you would have to do the grouping yourself. You could of-course use a fields
grouping to split the load across the windowed bolts. For trident you might
want to take a look at the windowing apis that wer
Hi,
I have a stream with time series data from different regions. I would like
to group the stream by the different regions and to add up the values of the
last minute (time window) per region. The sums should be persisted to Redis
or something like this.
I already found out that Storm Trid
