Hi,
I want to create a bolt that keeps some kind of state (aggregate) about the
messages it has seen so far (i.e. web click stream).
Once such a bolt has gathered information I would like to get to that
information for an application I designing.
So far I've come up with two way of getting at thi
This uses Trident but I think it covers what you need:
https://github.com/eshioji/trident-tutorial/blob/master/src/main/java/tutorial/storm/trident/Part04_BasicStateAndDRPC.java
On Sat, Feb 15, 2014 at 8:17 PM, Niels Basjes wrote:
> Hi,
>
> I want to create a bolt that keeps some kind of state
Thanks for the pointer. I''ll have a close look at this.
Is there also an example in 'plain' storm api?
Niels
On Feb 16, 2014 11:14 AM, "Enno Shioji" wrote:
> This uses Trident but I think it covers what you need:
>
> https://github.com/eshioji/trident-tutorial/blob/master/src/main/java/tutorial
