July 2017
Intermediate to advanced
796 pages
18h 55m
English
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]
Read now
Unlock full access