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 <[email protected]> wrote: > 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 this data: > 1) Persist it into something like HBase (i.e push from the bolt). > 2) Use DRPC to query the bolt state directly. > > Regarding this last idea (using DRPC): Is this possible? > If it is then where can I find an example on how to create a single > topology that is essentially both streaming and drpc. > > Thanks. > > -- > Best regards, > > Niels Basjes >
