JavaDStream<String> inputStream = ssc.queueStream(rddQueue); Can this rddQueue be of dynamic type in nature .If yes then how to make it run untill rddQueue is not finished .
Any other way to get rddQueue from a dynamically updatable Normal Queue . -- Thanks & Regards, SERC-IISC Anshu Shukla
