[SPARK-17628] change name StreamingExamples to be StreamingExamplesUt…

…ils, more descriptive
apache · Sep 22, 2016 · 79533fd · 79533fd
1 parent 7cbe216
commit 79533fd
Show file tree

Hide file tree

Showing 21 changed files with 22 additions and 22 deletions.
diff --git a/examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java b/examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java
@@ -64,7 +64,7 @@ public static void main(String[] args) throws Exception {
       System.exit(1);
     }
 
-    StreamingExamples.setStreamingLogLevels();
+    StreamingExamplesUtils.setStreamingLogLevels();
 
     // Create the context with a 1 second batch size
     SparkConf sparkConf = new SparkConf().setAppName("JavaCustomReceiver");

diff --git a/examples/src/main/java/org/apache/spark/examples/streaming/JavaDirectKafkaWordCount.java b/examples/src/main/java/org/apache/spark/examples/streaming/JavaDirectKafkaWordCount.java
@@ -57,7 +57,7 @@ public static void main(String[] args) throws Exception {
       System.exit(1);
     }
 
-    StreamingExamples.setStreamingLogLevels();
+    StreamingExamplesUtils.setStreamingLogLevels();
 
     String brokers = args[0];
     String topics = args[1];

diff --git a/examples/src/main/java/org/apache/spark/examples/streaming/JavaFlumeEventCount.java b/examples/src/main/java/org/apache/spark/examples/streaming/JavaFlumeEventCount.java
@@ -49,7 +49,7 @@ public static void main(String[] args) throws Exception {
       System.exit(1);
     }
 
-    StreamingExamples.setStreamingLogLevels();
+    StreamingExamplesUtils.setStreamingLogLevels();
 
     String host = args[0];
     int port = Integer.parseInt(args[1]);

diff --git a/examples/src/main/java/org/apache/spark/examples/streaming/JavaKafkaWordCount.java b/examples/src/main/java/org/apache/spark/examples/streaming/JavaKafkaWordCount.java
@@ -63,7 +63,7 @@ public static void main(String[] args) throws Exception {
       System.exit(1);
     }
 
-    StreamingExamples.setStreamingLogLevels();
+    StreamingExamplesUtils.setStreamingLogLevels();
     SparkConf sparkConf = new SparkConf().setAppName("JavaKafkaWordCount");
     // Create the context with 2 seconds batch size
     JavaStreamingContext jssc = new JavaStreamingContext(sparkConf, new Duration(2000));

diff --git a/examples/src/main/java/org/apache/spark/examples/streaming/JavaNetworkWordCount.java b/examples/src/main/java/org/apache/spark/examples/streaming/JavaNetworkWordCount.java
@@ -54,7 +54,7 @@ public static void main(String[] args) throws Exception {
       System.exit(1);
     }
 
-    StreamingExamples.setStreamingLogLevels();
+    StreamingExamplesUtils.setStreamingLogLevels();
 
     // Create the context with a 1 second batch size
     SparkConf sparkConf = new SparkConf().setAppName("JavaNetworkWordCount");

diff --git a/examples/src/main/java/org/apache/spark/examples/streaming/JavaQueueStream.java b/examples/src/main/java/org/apache/spark/examples/streaming/JavaQueueStream.java
@@ -41,7 +41,7 @@ private JavaQueueStream() {
 
   public static void main(String[] args) throws Exception {
 
-    StreamingExamples.setStreamingLogLevels();
+    StreamingExamplesUtils.setStreamingLogLevels();
     SparkConf sparkConf = new SparkConf().setAppName("JavaQueueStream");
 
     // Create the context

diff --git a/examples/src/main/java/org/apache/spark/examples/streaming/JavaSqlNetworkWordCount.java b/examples/src/main/java/org/apache/spark/examples/streaming/JavaSqlNetworkWordCount.java
@@ -58,7 +58,7 @@ public static void main(String[] args) throws Exception {
       System.exit(1);
     }
 
-    StreamingExamples.setStreamingLogLevels();
+    StreamingExamplesUtils.setStreamingLogLevels();
 
     // Create the context with a 1 second batch size
     SparkConf sparkConf = new SparkConf().setAppName("JavaSqlNetworkWordCount");

diff --git a/examples/src/main/java/org/apache/spark/examples/streaming/JavaStatefulNetworkWordCount.java b/examples/src/main/java/org/apache/spark/examples/streaming/JavaStatefulNetworkWordCount.java
@@ -56,7 +56,7 @@ public static void main(String[] args) throws Exception {
       System.exit(1);
     }
 
-    StreamingExamples.setStreamingLogLevels();
+    StreamingExamplesUtils.setStreamingLogLevels();
 
     // Create the context with a 1 second batch size
     SparkConf sparkConf = new SparkConf().setAppName("JavaStatefulNetworkWordCount");

diff --git a/examples/src/main/scala/org/apache/spark/examples/streaming/CustomReceiver.scala b/examples/src/main/scala/org/apache/spark/examples/streaming/CustomReceiver.scala
@@ -44,7 +44,7 @@ object CustomReceiver {
       System.exit(1)
     }
 
-    StreamingExamples.setStreamingLogLevels()
+    StreamingExamplesUtils.setStreamingLogLevels()
 
     // Create the context with a 1 second batch size
     val sparkConf = new SparkConf().setAppName("CustomReceiver")

diff --git a/examples/src/main/scala/org/apache/spark/examples/streaming/DirectKafkaWordCount.scala b/examples/src/main/scala/org/apache/spark/examples/streaming/DirectKafkaWordCount.scala
@@ -46,7 +46,7 @@ object DirectKafkaWordCount {
       System.exit(1)
     }
 
-    StreamingExamples.setStreamingLogLevels()
+    StreamingExamplesUtils.setStreamingLogLevels()
 
     val Array(brokers, topics) = args
 

diff --git a/examples/src/main/scala/org/apache/spark/examples/streaming/FlumeEventCount.scala b/examples/src/main/scala/org/apache/spark/examples/streaming/FlumeEventCount.scala
@@ -47,7 +47,7 @@ object FlumeEventCount {
       System.exit(1)
     }
 
-    StreamingExamples.setStreamingLogLevels()
+    StreamingExamplesUtils.setStreamingLogLevels()
 
     val Array(host, IntParam(port)) = args
 

diff --git a/examples/src/main/scala/org/apache/spark/examples/streaming/FlumePollingEventCount.scala b/examples/src/main/scala/org/apache/spark/examples/streaming/FlumePollingEventCount.scala
@@ -44,7 +44,7 @@ object FlumePollingEventCount {
       System.exit(1)
     }
 
-    StreamingExamples.setStreamingLogLevels()
+    StreamingExamplesUtils.setStreamingLogLevels()
 
     val Array(host, IntParam(port)) = args
 

diff --git a/examples/src/main/scala/org/apache/spark/examples/streaming/HdfsWordCount.scala b/examples/src/main/scala/org/apache/spark/examples/streaming/HdfsWordCount.scala
@@ -39,7 +39,7 @@ object HdfsWordCount {
       System.exit(1)
     }
 
-    StreamingExamples.setStreamingLogLevels()
+    StreamingExamplesUtils.setStreamingLogLevels()
     val sparkConf = new SparkConf().setAppName("HdfsWordCount")
     // Create the context
     val ssc = new StreamingContext(sparkConf, Seconds(2))

diff --git a/examples/src/main/scala/org/apache/spark/examples/streaming/KafkaWordCount.scala b/examples/src/main/scala/org/apache/spark/examples/streaming/KafkaWordCount.scala
@@ -46,7 +46,7 @@ object KafkaWordCount {
       System.exit(1)
     }
 
-    StreamingExamples.setStreamingLogLevels()
+    StreamingExamplesUtils.setStreamingLogLevels()
 
     val Array(zkQuorum, group, topics, numThreads) = args
     val sparkConf = new SparkConf().setAppName("KafkaWordCount")

diff --git a/examples/src/main/scala/org/apache/spark/examples/streaming/NetworkWordCount.scala b/examples/src/main/scala/org/apache/spark/examples/streaming/NetworkWordCount.scala
@@ -40,7 +40,7 @@ object NetworkWordCount {
       System.exit(1)
     }
 
-    StreamingExamples.setStreamingLogLevels()
+    StreamingExamplesUtils.setStreamingLogLevels()
 
     // Create the context with a 1 second batch size
     val sparkConf = new SparkConf().setAppName("NetworkWordCount")

diff --git a/examples/src/main/scala/org/apache/spark/examples/streaming/QueueStream.scala b/examples/src/main/scala/org/apache/spark/examples/streaming/QueueStream.scala
@@ -27,7 +27,7 @@ object QueueStream {
 
   def main(args: Array[String]) {
 
-    StreamingExamples.setStreamingLogLevels()
+    StreamingExamplesUtils.setStreamingLogLevels()
     val sparkConf = new SparkConf().setAppName("QueueStream")
     // Create the context
     val ssc = new StreamingContext(sparkConf, Seconds(1))

diff --git a/examples/src/main/scala/org/apache/spark/examples/streaming/RawNetworkGrep.scala b/examples/src/main/scala/org/apache/spark/examples/streaming/RawNetworkGrep.scala
@@ -43,7 +43,7 @@ object RawNetworkGrep {
       System.exit(1)
     }
 
-    StreamingExamples.setStreamingLogLevels()
+    StreamingExamplesUtils.setStreamingLogLevels()
 
     val Array(IntParam(numStreams), host, IntParam(port), IntParam(batchMillis)) = args
     val sparkConf = new SparkConf().setAppName("RawNetworkGrep")

diff --git a/examples/src/main/scala/org/apache/spark/examples/streaming/SqlNetworkWordCount.scala b/examples/src/main/scala/org/apache/spark/examples/streaming/SqlNetworkWordCount.scala
@@ -44,7 +44,7 @@ object SqlNetworkWordCount {
       System.exit(1)
     }
 
-    StreamingExamples.setStreamingLogLevels()
+    StreamingExamplesUtils.setStreamingLogLevels()
 
     // Create the context with a 2 second batch size
     val sparkConf = new SparkConf().setAppName("SqlNetworkWordCount")

diff --git a/examples/src/main/scala/org/apache/spark/examples/streaming/StatefulNetworkWordCount.scala b/examples/src/main/scala/org/apache/spark/examples/streaming/StatefulNetworkWordCount.scala
@@ -41,7 +41,7 @@ object StatefulNetworkWordCount {
       System.exit(1)
     }
 
-    StreamingExamples.setStreamingLogLevels()
+    StreamingExamplesUtils.setStreamingLogLevels()
 
     val sparkConf = new SparkConf().setAppName("StatefulNetworkWordCount")
     // Create the context with a 1 second batch size

diff --git a/...xamples/streaming/StreamingExamples.scala → ...es/streaming/StreamingExamplesUtils.scala b/...xamples/streaming/StreamingExamples.scala → ...es/streaming/StreamingExamplesUtils.scala
@@ -22,7 +22,7 @@ import org.apache.log4j.{Level, Logger}
 import org.apache.spark.internal.Logging
 
 /** Utility functions for Spark Streaming examples. */
-object StreamingExamples extends Logging {
+object StreamingExamplesUtils extends Logging {
 
   /** Set reasonable logging levels for streaming if the user has not configured log4j. */
   def setStreamingLogLevels() {

diff --git a/examples/src/main/scala/org/apache/spark/examples/streaming/clickstream/PageViewStream.scala b/examples/src/main/scala/org/apache/spark/examples/streaming/clickstream/PageViewStream.scala
@@ -18,7 +18,7 @@
 // scalastyle:off println
 package org.apache.spark.examples.streaming.clickstream
 
-import org.apache.spark.examples.streaming.StreamingExamples
+import org.apache.spark.examples.streaming.StreamingExamplesUtils
 import org.apache.spark.streaming.{Seconds, StreamingContext}
 
 // scalastyle:off
@@ -42,7 +42,7 @@ object PageViewStream {
                          " errorRatePerZipCode, activeUserCount, popularUsersSeen")
       System.exit(1)
     }
-    StreamingExamples.setStreamingLogLevels()
+    StreamingExamplesUtils.setStreamingLogLevels()
     val metric = args(0)
     val host = args(1)
     val port = args(2).toInt