[HOTFIX] SPARK-1637: There are some Streaming examples added after th…

…e PR #571 was last updated. This resulted in Compilation Errors. cc @mateiz project not compiling currently. Author: Sandeep <sandeep@techaddict.me> Closes #673 from techaddict/SPARK-1637-HOTFIX and squashes the following commits: b512f4f [Sandeep] [SPARK-1637][HOTFIX] There are some Streaming examples added after the PR #571 was last updated. This resulted in Compilation Errors.
apache · May 7, 2014 · fdae095 · fdae095
1 parent 48ba3b8
commit fdae095
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 6 deletions.
diff --git a/...treaming/examples/JavaCustomReceiver.java → ...xamples/streaming/JavaCustomReceiver.java b/...treaming/examples/JavaCustomReceiver.java → ...xamples/streaming/JavaCustomReceiver.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.spark.streaming.examples;
+package org.apache.spark.examples.streaming;
 
 import com.google.common.collect.Lists;
 
@@ -48,7 +48,7 @@
  * To run this on your local machine, you need to first run a Netcat server
  *    `$ nc -lk 9999`
  * and then run the example
- *    `$ ./run org.apache.spark.streaming.examples.JavaCustomReceiver local[2] localhost 9999`
+ *    `$ ./run org.apache.spark.examples.streaming.JavaCustomReceiver local[2] localhost 9999`
  */
 
 public class JavaCustomReceiver extends Receiver<String> {
@@ -149,5 +149,3 @@ private void receive() {
     }
   }
 }
-
-
diff --git a/...k/streaming/examples/CustomReceiver.scala → ...k/examples/streaming/CustomReceiver.scala b/...k/streaming/examples/CustomReceiver.scala → ...k/examples/streaming/CustomReceiver.scala
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.spark.streaming.examples
+package org.apache.spark.examples.streaming
 
 import java.io.{InputStreamReader, BufferedReader, InputStream}
 import java.net.Socket
@@ -37,7 +37,7 @@ import org.apache.spark.streaming.receiver.Receiver
  * To run this on your local machine, you need to first run a Netcat server
  *    `$ nc -lk 9999`
  * and then run the example
- *    `$ ./run org.apache.spark.streaming.examples.CustomReceiver local[2] localhost 9999`
+ *    `$ ./run org.apache.spark.examples.streaming.CustomReceiver local[2] localhost 9999`
  */
 object CustomReceiver {
   def main(args: Array[String]) {