From 126608a02b55287684762811b0ade99dbce7d109 Mon Sep 17 00:00:00 2001 From: Prabeesh K Date: Thu, 30 Jul 2015 14:02:24 +0400 Subject: [PATCH] address the comments --- .../src/main/python/streaming/mqtt_wordcount.py | 15 ++++++++------- 1 file changed, 8 insertions(+), 7 deletions(-) diff --git a/examples/src/main/python/streaming/mqtt_wordcount.py b/examples/src/main/python/streaming/mqtt_wordcount.py index 0fb585e58fbe4..617ce5ea6775e 100644 --- a/examples/src/main/python/streaming/mqtt_wordcount.py +++ b/examples/src/main/python/streaming/mqtt_wordcount.py @@ -18,13 +18,14 @@ """ A sample wordcount with MqttStream stream Usage: mqtt_wordcount.py - To work with Mqtt, Mqtt Message broker/server required. - Mosquitto (http://mosquitto.org/) is an open source Mqtt Broker - In ubuntu mosquitto can be installed using the command `$ sudo apt-get install mosquitto` - Run Mqtt publisher as - `$ bin/run-example \ - org.apache.spark.examples.streaming.MQTTPublisher tcp://localhost:1883 foo` - and then run the example as + + To run this in your local machine, you need to setup a MQTT broker and publisher first, + Mosquitto is one of the open source MQTT Brokers, see + http://mosquitto.org/ + Eclipse paho project provides number of clients and utilities for working with MQTT, see + http://www.eclipse.org/paho/#getting-started + + and then run the example `$ bin/spark-submit --jars external/mqtt-assembly/target/scala-*/\ spark-streaming-mqtt-assembly-*.jar examples/src/main/python/streaming/mqtt_wordcount.py \ tcp://localhost:1883 foo`