Re: Hopping Window

2019-02-01 Thread Matthias J. Sax
Compare: https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Stream+Usage+Patterns -Matthias On 1/29/19 8:50 AM, Rene Richard wrote: > I think I figured out my problem!!! > > > 19/01/29 12:40:01 INFO HBProcessor: > - > 19/01/

Re: Hopping Window

2019-01-29 Thread Rene Richard
I think I figured out my problem!!! 19/01/29 12:40:01 INFO HBProcessor: - 19/01/29 12:40:01 INFO HBProcessor: Heart Rate -> K : [1], V : [{"userId":"1","beatCount":60,"addTime":154878652}] 19/01/29 12:40:01 INFO HBProcessor: -

Hopping Window

2019-01-29 Thread Rene Richard
Hello, I’ve been struggling for a while now with Kafka windows. I want to calculate an average heart rate on a 5 minute window. I have three apps : 1)- A heart beat generator. It starts at the top of the minute (second 0). Sends between 60 to 70 beats using a producer. The event time is set wi