Hi, I'd suggest to have a look at the window operators [1]. For example a tumbling window of 1 minute can be used to compute metrics every minute. Flink's window operators are very extensible and you can implement very custom logic if the predefined windows don't match your use case. In any case, windows are used to collect and perform a computation on a set of records.
Best, Fabian [1] https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/windows.html 2017-10-05 12:57 GMT+02:00 Rahul Raj <rahulrajms...@gmail.com>: > Hi, > > I have to calculate some complicated metrics like click through rate , > click value rate and conversions on real time data using flink. But I am > not sure what functionality of flink should I use to program this because > it involves collection of some records in memory for certain time may be 1 > minute and then using formula for calculating metrics on those records. > > Am I correct with my approach or is there any preferred approach for such > tasks in flink? Can I use windows for doing this? Any tutorial or example > would be really great. > > Rahul Raj >
