Create an input stream with any arbitrary user implemented receiver. It can be customized to meet the use cases.
Find more details at http://spark.apache.org/docs/latest/streaming-custom-receivers.html.
Following is the API declaration for the receiverStream:
def receiverStream[T: ClassTag](receiver: Receiver[T]): ReceiverInputDStream[T