将 DStream 转换为 RDD

Maj*_*aba 7 apache-spark spark-streaming

如何将 DStream 转换为 RDD?我知道我们可以使用transformforEachRDD方法来操作 dstream 的底层 rdd,但我想在驱动程序中使用 rdd。例如,在队列流示例中添加像最后行一样的队列