我如何将DStream转换为RDD？我知道我们可以使用 transform 或 forEachRDD 方法来操纵dstream的底层rdd，但我想在驱动程序中使用rdd . 例如，添加像QueueStream Example中的最后一行一样的队列
我如何将DStream转换为RDD？我知道我们可以使用 transform 或 forEachRDD 方法来操纵dstream的底层rdd，但我想在驱动程序中使用rdd . 例如，添加像QueueStream Example中的最后一行一样的队列