Re: Spark Streaming - processing/transforming DStreams using a custom Receiver

2016-02-25 Thread Bryan Cutler
ring] (instead of DStream[Char]), where each string in the > DStream represents a timestamp from a RDD? Secondly, can someone give some > good examples of this? And thirdly, which functions is at best to use if I > would like to e.g. aggregate all events per repository ID. I.e. each Event > objec

Spark Streaming - processing/transforming DStreams using a custom Receiver

2016-02-25 Thread Dominik Safaric
park-user-list.1001560.n3.nabble.com/Spark-Streaming-processing-transforming-DStreams-using-a-custom-Receiver-tp26336.html Sent from the Apache Spark User List mailing list archive at Nabble.com. - To unsubscribe, e-mail: user-uns