Fixed scala style errors.

Author: tdas

examples/src/main/scala/org/apache/spark/examples/streaming/FlumeEventCount.scala

@@ -41,7 +41,7 @@ import org.apache.spark.util.IntParam
  */
 object FlumeEventCount {
   def main(args: Array[String]) {
-    if (args.length != 3) {
+    if (args.length < 2) {
       System.err.println(
         "Usage: FlumeEventCount <host> <port>")
       System.exit(1)

examples/src/main/scala/org/apache/spark/examples/streaming/HdfsWordCount.scala

@@ -28,7 +28,7 @@ import org.apache.spark.streaming.StreamingContext._
  *
  * To run this on your local machine on directory `localdir`, run this example
  *    `$ bin/run-example \
-  *     org.apache.spark.examples.streaming.HdfsWordCount localdir`
+ *       org.apache.spark.examples.streaming.HdfsWordCount localdir`
  *
  * Then create a text file in `localdir` and the words in the file will get counted.
  */

examples/src/main/scala/org/apache/spark/examples/streaming/MQTTWordCount.scala

@@ -75,12 +75,14 @@ object MQTTPublisher {
  * Example Java code for Mqtt Publisher and Subscriber can be found here
  * https://bitbucket.org/mkjinesh/mqttclient
  * Usage: MQTTWordCount <MqttbrokerUrl> <topic>
-\ *   <MqttbrokerUrl> and <topic> describe where Mqtt publisher is running.
+ *   <MqttbrokerUrl> and <topic> describe where Mqtt publisher is running.
  *
  * To run this example locally, you may run publisher as
- *    `$ ./bin/run-example org.apache.spark.examples.streaming.MQTTPublisher tcp://localhost:1883 foo`
+ *    `$ bin/run-example \
+ *      org.apache.spark.examples.streaming.MQTTPublisher tcp://localhost:1883 foo`
  * and run the example as
- *    `$ ./bin/run-example org.apache.spark.examples.streaming.MQTTWordCount tcp://localhost:1883 foo`
+ *    `$ bin/run-example \
+ *      org.apache.spark.examples.streaming.MQTTWordCount tcp://localhost:1883 foo`
  */
 object MQTTWordCount {
 

examples/src/main/scala/org/apache/spark/examples/streaming/TwitterPopularTags.scala

@@ -34,8 +34,8 @@ import org.apache.spark.SparkConf
 object TwitterPopularTags {
   def main(args: Array[String]) {
     if (args.length < 4) {
-      System.err.println("Usage: TwitterPopularTags <consumer key> <consumer secret> <access token> " +
-        "<access token secret> [<filters>]")
+      System.err.println("Usage: TwitterPopularTags <consumer key> <consumer secret> " +
+        "<access token> <access token secret> [<filters>]")
       System.exit(1)
     }