org.apache.spark.streaming.mqtt

Class MQTTUtils

java.lang.Object

org.apache.spark.streaming.mqtt.MQTTUtils

public class MQTTUtils
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
MQTTUtils()

Method Summary

Methods

Modifier and Type	Method and Description
static JavaReceiverInputDStream<java.lang.String>	createStream(JavaStreamingContext jssc, java.lang.String brokerUrl, java.lang.String topic) Create an input stream that receives messages pushed by a MQTT publisher.
static JavaReceiverInputDStream<java.lang.String>	createStream(JavaStreamingContext jssc, java.lang.String brokerUrl, java.lang.String topic, StorageLevel storageLevel) Create an input stream that receives messages pushed by a MQTT publisher.
static ReceiverInputDStream<java.lang.String>	createStream(StreamingContext ssc, java.lang.String brokerUrl, java.lang.String topic, StorageLevel storageLevel) Create an input stream that receives messages pushed by a MQTT publisher.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MQTTUtils

public MQTTUtils()

Method Detail

createStream

public static ReceiverInputDStream<java.lang.String> createStream(StreamingContext ssc,
                                                  java.lang.String brokerUrl,
                                                  java.lang.String topic,
                                                  StorageLevel storageLevel)

Create an input stream that receives messages pushed by a MQTT publisher.

Parameters:

ssc - StreamingContext object

brokerUrl - Url of remote MQTT publisher

topic - Topic name to subscribe to

storageLevel - RDD storage level. Defaults to StorageLevel.MEMORY_AND_DISK_SER_2.

Returns:

(undocumented)

createStream

public static JavaReceiverInputDStream<java.lang.String> createStream(JavaStreamingContext jssc,
                                                      java.lang.String brokerUrl,
                                                      java.lang.String topic)

Create an input stream that receives messages pushed by a MQTT publisher. Storage level of the data will be the default StorageLevel.MEMORY_AND_DISK_SER_2.

Parameters:

jssc - JavaStreamingContext object

brokerUrl - Url of remote MQTT publisher

topic - Topic name to subscribe to

Returns:

(undocumented)

createStream

public static JavaReceiverInputDStream<java.lang.String> createStream(JavaStreamingContext jssc,
                                                      java.lang.String brokerUrl,
                                                      java.lang.String topic,
                                                      StorageLevel storageLevel)

Create an input stream that receives messages pushed by a MQTT publisher.

Parameters:

jssc - JavaStreamingContext object

brokerUrl - Url of remote MQTT publisher

topic - Topic name to subscribe to

storageLevel - RDD storage level.

Returns:

(undocumented)