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*.

Reply via email to