Hi! Data streams are inifnite. It's quite hard to sort something infinite ;-) That's why the operation does not exist on DataStream.
Stephan On Wed, Aug 17, 2016 at 6:22 PM, subash basnet <yasub...@gmail.com> wrote: > Hello all, > > I found the *sortPartition()* function in dataset for ordering the > dataset elements as below: > DataSet<Tuple2<Integer, String>> data; > DataSet<Tuple2<Integer, String>> partitionedData = data.sortPartition(0, > Order.DESCENDING); > > But I couldn't find any methods to sort the elements in datastream. > DataStream<Tuple2<Integer, String>> data; > DataStream<Tuple2<Integer, String>> partitionedData =data.?? > > What could be the way to achieve sorting in datastream elements. > > > Best Regards, > Subash Basnet >
