flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Suneel Marthi <smar...@apache.org>
Subject Re: Suggestion for top 'k' products
Date Mon, 13 Mar 2017 17:29:17 GMT
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 <
vr1meghashyam@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
>

Mime
View raw message