Spark Streaming ZeroMQ Java Example

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

Spark Streaming ZeroMQ Java Example

goofy real
Reply | Threaded
Open this post in threaded view
|

Re: Spark Streaming ZeroMQ Java Example

Tathagata Das
Unfortunately there isnt one right now. But it is probably too hard to start with the JavaNetworkWordCount, and use the ZeroMQUtils in the same way as the Scala ZeroMQWordCount example. Basically you have to change this line and create a zeromq stream rather than a socketStream. Refer to ZeroMQUtils.createStream docs for more details.  

Would be great if you can contribute it back ;) 

TD




On Mon, Mar 24, 2014 at 11:28 PM, goofy real <[hidden email]> wrote: