diff options
Diffstat (limited to 'python/pyspark/streaming/mqtt.py')
| -rw-r--r-- | python/pyspark/streaming/mqtt.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/python/pyspark/streaming/mqtt.py b/python/pyspark/streaming/mqtt.py index f06598971c..fa83006c36 100644 --- a/python/pyspark/streaming/mqtt.py +++ b/python/pyspark/streaming/mqtt.py @@ -31,6 +31,7 @@ class MQTTUtils(object): storageLevel=StorageLevel.MEMORY_AND_DISK_SER_2): """ Create an input stream that pulls messages from a Mqtt Broker. + :param ssc: StreamingContext object :param brokerUrl: Url of remote mqtt publisher :param topic: topic name to subscribe to |