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:31:03 GMT
For an example implementation using Flink, check out

On Mon, Mar 13, 2017 at 1:29 PM, Suneel Marthi <smarthi@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 <
> 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

View raw message