Make MQTT lower case

Andrew Or · Andrew Or · commit fd07d22a2ace · 2015-05-15T13:26:57.000-07:00
diff --git a/external/mqtt/src/main/scala/org/apache/spark/streaming/mqtt/MQTTUtils.scala b/external/mqtt/src/main/scala/org/apache/spark/streaming/mqtt/MQTTUtils.scala
@@ -37,7 +37,7 @@ object MQTTUtils {
       brokerUrl: String,
       topic: String,
       storageLevel: StorageLevel = StorageLevel.MEMORY_AND_DISK_SER_2
-    ): ReceiverInputDStream[String] = ssc.withNamedScope("MQTT stream") {
+    ): ReceiverInputDStream[String] = ssc.withNamedScope("mqtt stream") {
     new MQTTInputDStream(ssc, brokerUrl, topic, storageLevel)
   }
 

Original file line number	Diff line number	Diff line change
`@@ -37,7 +37,7 @@ object MQTTUtils {`
`37`	`37`	`brokerUrl: String,`
`38`	`38`	`topic: String,`
`39`	`39`	`storageLevel: StorageLevel = StorageLevel.MEMORY_AND_DISK_SER_2`
`40`		`- ): ReceiverInputDStream[String] = ssc.withNamedScope("MQTT stream") {`
	`40`	`+ ): ReceiverInputDStream[String] = ssc.withNamedScope("mqtt stream") {`
`41`	`41`	`new MQTTInputDStream(ssc, brokerUrl, topic, storageLevel)`
`42`	`42`	`}`
`43`	`43`