Sapark Streaming ,window和RDD的转换问题

最近在研究Streaming

在例子NetworkWordCount中，我设置了一个window（30秒）间隔（10秒）

获取了很多单词后

我想把这个窗口做一个reduce后，根据所有单词出现的频率次数进行排序，应该怎么做？

我查过api，只有RDD方法的top方法或者sortbyvalue方法能达到，但Streaming里面基本上都是Dstream类型的。不能使用RDD的方法。

求解答