Your receiver must extend Receiver[String].Try changing it to extend
Receiver[Message]?
On Mon, Oct 12, 2015 at 2:03 PM, Something Something <
mailinglist...@gmail.com> wrote:
> In my custom receiver for Spark Streaming I've code such as this:
>
> messages.toArray().foreach(ms
In my custom receiver for Spark Streaming I've code such as this:
messages.toArray().foreach(msg => {
val m = msg.asInstanceOf[Message]
* store(m.getBody)*
})
Instead of 'body' which is of type 'String', I would rather pass the en
