Hi Daniela, Windowing support was recently added to storm master.
I think a time based tumbling window of 1 min duration is what you are looking for. Take a look at the windowing docs [1] and the example topology [2]. You also need to set ‘topology.message.timeout.secs’ more than 1 min and ‘topology.max.spout.pending' to be more than the max expected tuples in a minute. - Arun [1] https://github.com/apache/storm/blob/master/docs/documentation/Windowing.md [2] https://github.com/apache/storm/blob/master/examples/storm-starter/src/jvm/storm/starter/SlidingWindowTopology.java On 1/4/16, 1:54 AM, "Daniela Stoiber" <[email protected]> wrote: >Hello > > > >I have a question regarding Storm. I would like to calculate the sum of >values which I receive every minute from different devices. There are lots >of values from lots of different devices each minute. But I only want to use >the values of the current minute and then the next one and so on. The sum >should always be stored in a database or should be displayed on a dashboard. >Is it possible to use only the values of the current minute with e.g. a time >window or do I have to use e.g. the last five minutes to calculate the sum >of the values. > > > >Thank you very much in advance. > > > >Best regards, > >Daniela >
