diff options
| author | Sandeep <sandeep@techaddict.me> | 2014-05-06 21:55:05 -0700 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2014-05-06 21:55:05 -0700 |
| commit | fdae095de2daa1fc3b343c05e515235756d856a4 (patch) | |
| tree | 5d44a53dcee5aba25a38f4567f715b22c759520c /examples/src | |
| parent | 48ba3b8cdc3bdc7c67bc465d1f047fa3f44d7085 (diff) | |
| download | spark-fdae095de2daa1fc3b343c05e515235756d856a4.tar.gz spark-fdae095de2daa1fc3b343c05e515235756d856a4.tar.bz2 spark-fdae095de2daa1fc3b343c05e515235756d856a4.zip | |
[HOTFIX] SPARK-1637: There are some Streaming examples added after the 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.
Diffstat (limited to 'examples/src')
| -rw-r--r-- | examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java (renamed from examples/src/main/java/org/apache/spark/streaming/examples/JavaCustomReceiver.java) | 6 | ||||
| -rw-r--r-- | examples/src/main/scala/org/apache/spark/examples/streaming/CustomReceiver.scala (renamed from examples/src/main/scala/org/apache/spark/streaming/examples/CustomReceiver.scala) | 4 |
2 files changed, 4 insertions, 6 deletions
diff --git a/examples/src/main/java/org/apache/spark/streaming/examples/JavaCustomReceiver.java b/examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java index e36c7800be..7f558f3ee7 100644 --- a/examples/src/main/java/org/apache/spark/streaming/examples/JavaCustomReceiver.java +++ b/examples/src/main/java/org/apache/spark/examples/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 @@ import java.util.regex.Pattern; * 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 @@ public class JavaCustomReceiver extends Receiver<String> { } } } - - diff --git a/examples/src/main/scala/org/apache/spark/streaming/examples/CustomReceiver.scala b/examples/src/main/scala/org/apache/spark/examples/streaming/CustomReceiver.scala index eebffd8249..e317e2d36a 100644 --- a/examples/src/main/scala/org/apache/spark/streaming/examples/CustomReceiver.scala +++ b/examples/src/main/scala/org/apache/spark/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]) { |