How can I convert DStream to RDD? I know that we can use the transformor method forEachRDDto control the underlying rdd from dstream, but I want to use rdd inside the driver. For example, to add to the queue as the last lines in
QueueStream Example
source
share