For an example implementation using Flink, check out https://github.com/bigpetstore/bigpetstore-flink/blob/master/src/main/java/org/apache/bigtop/bigpetstore/flink/java/FlinkStreamingRecommender.java
On Mon, Mar 13, 2017 at 1:29 PM, Suneel Marthi <smar...@apache.org> wrote: > A simple way is to populate a Priority Queue of max size 'k' and > implement a comparator on ur records. That would ensure that u always have > Top k records at any instant in time. > > On Mon, Mar 13, 2017 at 1:25 PM, Meghashyam Sandeep V < > vr1meghash...@gmail.com> wrote: > >> Hi All, >> >> I'm trying to use Flink for a use case where I would want to see my top >> selling products in time windows in near real time (windows of size 1-2 >> mins if fine). I guess this is the most common use case to use streaming >> apis in e-commerce. I see that I can iterate over records in a windowed >> stream and do the sorting myself. I'm wondering if thats the best way. Is >> there any in built sort functionality that I missed anywhere in Flink docs? >> >> Thanks, >> Sandeep >> > >
