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 < [email protected]> 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 >
