Look at the existing topN accumulation. It should be a generalization, where you don't have a limit.
On Wed, Mar 8, 2017 at 8:05 AM, AJAY GUPTA <ajaygit...@gmail.com> wrote: > Hi, > > I would like to propose the Sort Accumulation. The accumulation will be > responsible for sorting the input POJO stream. The accumulation will > require a comparator to compare and sort the input tuples. Another boolean > parameter "sortDesc" will be used to decide sorting order. > > Let me know your views. > > Thanks, > Ajay >
