how about this? sorted = running_counts.map(lambda t: t[1],t[0]).sortByKey()
Basically swap key and value of the RDD and then sort? On Thu, Nov 12, 2015 at 8:53 AM, Amir Rahnama <amirrahn...@gmail.com> wrote: > Hey, > > Anybody knows how can one sort the result in the stateful example? > > Python would be prefered. > > > https://github.com/apache/spark/blob/859dff56eb0f8c63c86e7e900a12340c199e6247/examples/src/main/python/streaming/stateful_network_wordcount.py > -- > Thanks and Regards, > > Amir Hossein Rahnama > > *Tel: +46 (0) 761 681 102* > Website: www.ambodi.com > Twitter: @_ambodi <https://twitter.com/_ambodi> > -- Best Regards, Ayan Guha
