Send RDD in Streaming

DStreamSendRDD.scala

import org.apache.spark.rdd.RDD
import org.apache.spark.{SparkConf}
import org.apache.spark.streaming.{Seconds, StreamingContext}

object DStreamSendRDD extends App {
  val conf = new SparkConf().setMaster("local[*]").setAppName("StreamingTransformExample")
  val ssc = new StreamingContext(conf, Seconds(5))
  val rdd1 = ssc.sparkContext.parallelize(Array(1, 2, 3))
  val rddQueue = scala.collection.mutable.Queue[RDD[Int]]() //scala.collection.mutable.Queue[RDD[MyObject]]()
  rddQueue.enqueue(rdd1)
  val numsDStream = ssc.queueStream(rddQueue, true)
  val plusOneDStream = numsDStream.map(x => x + 1)
  plusOneDStream.print()
  ssc.start()
  ssc.awaitTermination()
}