To work with zeroMQ, some native libraries have to be installed.
Install zeroMQ (release 2.1) core libraries. [ZeroMQ Install guide](http://www.zeromq.org/intro:get-the-software)
Usage: ZeroMQWordCount <master> <zeroMQurl> <topic>
In local mode, <master> should be 'local[n]' with n > 1
<zeroMQurl> and <topic> describe where zeroMq publisher is running.
To run this example locally, you may run publisher as
$ ./bin/run-example org.apache.spark.streaming.examples.SimpleZeroMQPublisher tcp://127.0.1.1:1234 foo.bar
and run the example as
$ ./bin/run-example org.apache.spark.streaming.examples.ZeroMQWordCount local[2] tcp://127.0.1.1:1234 foo
A sample wordcount with ZeroMQStream stream
To work with zeroMQ, some native libraries have to be installed. Install zeroMQ (release 2.1) core libraries. [ZeroMQ Install guide](http://www.zeromq.org/intro:get-the-software)
Usage: ZeroMQWordCount <master> <zeroMQurl> <topic> In local mode, <master> should be 'local[n]' with n > 1 <zeroMQurl> and <topic> describe where zeroMq publisher is running.
To run this example locally, you may run publisher as
$ ./bin/run-example org.apache.spark.streaming.examples.SimpleZeroMQPublisher tcp://127.0.1.1:1234 foo.bar
and run the example as$ ./bin/run-example org.apache.spark.streaming.examples.ZeroMQWordCount local[2] tcp://127.0.1.1:1234 foo