Create an input stream from a queue of RDDs. In each batch, it will process either one or all of the RDDs returned by the queue:
def queueStream[T: ClassTag](queue: Queue[RDD[T]], oneAtATime: Boolean = true): InputDStream[T]
Create an input stream from a queue of RDDs. In each batch, it will process either one or all of the RDDs returned by the queue:
def queueStream[T: ClassTag](queue: Queue[RDD[T]], oneAtATime: Boolean = true): InputDStream[T]