You can compute the average and std-dev in a WindowFunction that iterates over all records in the window (6h / 15min = 24). WIndowFunction [1] and CoProcessFunction [2] are described in the docs.
[1] https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/windows.html#windowfunction---the-generic-case [2] https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/stream/process_function.html#low-level-joins 2017-07-31 19:23 GMT+02:00 Raj Kumar <smallthings1...@gmail.com>: > Thanks Fabian. > > Can you provide more details about the implementation for step 2 and step > 3. > > How to calculate the average and standard deviation ? > How does the coprocess function work ? Can you provide details about these > two. > > > > -- > View this message in context: http://apache-flink-user- > mailing-list-archive.2336050.n4.nabble.com/Access-Sliding- > window-tp14519p14564.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >
