If you need something to be done at a regular interval within Storm you might wanna leverage the "tick tuple" concept:
- http://kitmenke.com/blog/2014/08/04/tick-tuples-within-storm/ On Fri, May 6, 2016 at 11:53 PM, Daniela S <[email protected]> wrote: > Hi, > > I would like to use Redis as a kind of cache for my active devices. So i > receive a message over Kafka with an active device and store it in Redis. > Now I would like to pull all active devices from Redis and to add a > specific value to each device and to build a sum afterwards. > How can I ensure that the spout fetches the list of active devices e.g. > every minute? Because the sum has to be built every minute from scratch, as > the additional specific value changes every minute for every device. > > Thank you in advance. > > Regards, > Daniela >
