Use only latest values

2016-04-08 Thread Maria Musterfrau
Hi, I would like to cache values and to use only the latest "valid" values to build a sum. In more detail, I receive values from devices periodically. I would like to add up all the valid values each minute. But not every device sends a new value every minute. And as long as there is no new

Fw: Combining group by and time window

2016-03-30 Thread Maria Musterfrau
Does anyone have an idea?   Thank you in advance.   Regards, Daniela   Gesendet: Montag, 28. März 2016 um 21:06 Uhr Von: "Maria Musterfrau" <daniela_4...@gmx.at> An: user@storm.apache.org Betreff: Combining group by and time window Hi,   I have a stream with time

"Prediction" with known values

2016-03-09 Thread Maria Musterfrau
Hello   I have a question regarding Storm. I would like to predict the next hour in realtime. But it is not really a prediction as I already know the values. I receive a message which tells me that a program has been started. Every program has a list of values (every minute a different value for