The average would be computed over the aggregated 15-minute count values. The sliding window would emit every 15 minutes the average of all records that arrived within the last 6 hours. Since the preceding 15-minute tumbling window emits 1 record every 15 mins, this would be the avg over 24 records.
So, it would be running with a "granularity" of 15 minutes. Best, Fabian 2017-08-01 4:48 GMT+02:00 Raj Kumar <smallthings1...@gmail.com>: > Thanks Fabian. That helps. > > I have one more question. In the second step since I am using window > function apply, The average calculated will be a running average or it will > be computed at the end of 6hrs window ?? > > > > -- > View this message in context: http://apache-flink-user- > mailing-list-archive.2336050.n4.nabble.com/Access-Sliding- > window-tp14519p14584.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >
