Do you just want to write some unit tests? If so, you can use "queueStream" to create a DStream from a queue of RDDs. However, because it doesn't support metadata checkpointing, it's better to only use it in unit tests.
On Fri, Jan 29, 2016 at 7:35 AM, Sateesh Karuturi < sateesh.karutu...@gmail.com> wrote: > Anyone please help me out how to create a DStream from existing RDD. My > code is: > > JavaSparkContext ctx = new JavaSparkContext(conf);JavaRDD<String> rddd = > ctx.parallelize(arraylist); > > Now i need to use these *rddd* as input to *JavaStreamingContext*. >
