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 <
[hidden email]>:
> 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
>