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