July 2017
Intermediate to advanced
796 pages
18h 55m
English
Create an input stream with any arbitrary user implemented receiver. It can be customized to meet the use cases.
Following is the API declaration for the receiverStream:
def receiverStream[T: ClassTag](receiver: Receiver[T]): ReceiverInputDStream[T
Read now
Unlock full access