I just merged support for local output sorting yesterday :-) This allows to sort the data before it is given to the OutputFormat.
It is done like this: myData.write(myOF).sortLocalOutput(1, Order.ASCENDING); See the programming guide for details (only in master, not online). Full sorting can be done with a DOP=1 data sink. Full parallel sorting is not supported yet (requires range partitioning and data stats for good partitioning bins). Best, Fabian 2015-02-04 14:38 GMT+01:00 Timo Walther <twal...@apache.org>: > Hey, > > is it correct that we currently do not support sorting without any > grouping? I had this question by 2 users in the last weeks and now I also > need this functionality. > > > Is it possible to sort e.g. a word count result Tuple2<String, Integer> by > count? > > > Regards, > Timo >
