Thanks for the response. So, i am guessing windows in flink will store the records in memory before processing them. Correct?
Rahul Raj On Oct 5, 2017 17:50, "Fabian Hueske" <fhue...@gmail.com> wrote: > 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 >> > >
