Anyone please help me out how to create a DStream from existing RDD. My
code is:
JavaSparkContext ctx = new JavaSparkContext(conf);JavaRDD rddd
= ctx.parallelize(arraylist);
Now i need to use these *rddd* as input to *JavaStreamingContext*.
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 <
