projects / bahir.git / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: ab62371) | patch
[BAHIR-53] Add new configuration options to MQTTInputDStream
authorSebastian Woehrl <sebastian.woehrl@maibornwolff.de>
Sat, 13 Aug 2016 13:00:13 +0000 (15:00 +0200)
committerLuciano Resende <lresende@apache.org>
Mon, 22 Aug 2016 19:38:28 +0000 (12:38 -0700)
commit28f034f49d19034b596f7f04ca4fc2698a21ad6c
tree796225945849c005bcc51870bd367950fb6d1202tree | snapshot
parentab62371e06824e4388eccc15e32b619a11997490commit | diff
[BAHIR-53] Add new configuration options to MQTTInputDStream

Add new configuration options to enable secured connections and
other quality of services.

Closes #23
scalastyle-config.xml diff | blob | history
streaming-mqtt/README.md diff | blob | history
streaming-mqtt/src/main/scala/org/apache/spark/streaming/mqtt/MQTTInputDStream.scala diff | blob | history
streaming-mqtt/src/main/scala/org/apache/spark/streaming/mqtt/MQTTUtils.scala diff | blob | history
streaming-mqtt/src/test/java/org/apache/spark/streaming/mqtt/JavaMQTTStreamSuite.java diff | blob | history
Apache Bahir