File tree Expand file tree Collapse file tree 1 file changed +8
-7
lines changed
examples/src/main/python/streaming Expand file tree Collapse file tree 1 file changed +8
-7
lines changed Original file line number Diff line number Diff line change 18
18
"""
19
19
A sample wordcount with MqttStream stream
20
20
Usage: mqtt_wordcount.py <broker url> <topic>
21
- To work with Mqtt, Mqtt Message broker/server required.
22
- Mosquitto (http://mosquitto.org/) is an open source Mqtt Broker
23
- In ubuntu mosquitto can be installed using the command `$ sudo apt-get install mosquitto`
24
- Run Mqtt publisher as
25
- `$ bin/run-example \
26
- org.apache.spark.examples.streaming.MQTTPublisher tcp://localhost:1883 foo`
27
- and then run the example as
21
+
22
+ To run this in your local machine, you need to setup a MQTT broker and publisher first,
23
+ Mosquitto is one of the open source MQTT Brokers, see
24
+ http://mosquitto.org/
25
+ Eclipse paho project provides number of clients and utilities for working with MQTT, see
26
+ http://www.eclipse.org/paho/#getting-started
27
+
28
+ and then run the example
28
29
`$ bin/spark-submit --jars external/mqtt-assembly/target/scala-*/\
29
30
spark-streaming-mqtt-assembly-*.jar examples/src/main/python/streaming/mqtt_wordcount.py \
30
31
tcp://localhost:1883 foo`
You can’t perform that action at this time.
0 commit comments