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
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 <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
>>
>
>

Mime
View raw message