Skip to content
Snippets Groups Projects
Commit fdae095d authored by Sandeep's avatar Sandeep Committed by Patrick Wendell
Browse files

[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.
parent 48ba3b8c
No related branches found
No related tags found
No related merge requests found
...@@ -15,7 +15,7 @@ ...@@ -15,7 +15,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.apache.spark.streaming.examples; package org.apache.spark.examples.streaming;
import com.google.common.collect.Lists; import com.google.common.collect.Lists;
...@@ -48,7 +48,7 @@ import java.util.regex.Pattern; ...@@ -48,7 +48,7 @@ import java.util.regex.Pattern;
* To run this on your local machine, you need to first run a Netcat server * To run this on your local machine, you need to first run a Netcat server
* `$ nc -lk 9999` * `$ nc -lk 9999`
* and then run the example * 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> { public class JavaCustomReceiver extends Receiver<String> {
...@@ -149,5 +149,3 @@ public class JavaCustomReceiver extends Receiver<String> { ...@@ -149,5 +149,3 @@ public class JavaCustomReceiver extends Receiver<String> {
} }
} }
} }
...@@ -15,7 +15,7 @@ ...@@ -15,7 +15,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.apache.spark.streaming.examples package org.apache.spark.examples.streaming
import java.io.{InputStreamReader, BufferedReader, InputStream} import java.io.{InputStreamReader, BufferedReader, InputStream}
import java.net.Socket import java.net.Socket
...@@ -37,7 +37,7 @@ import org.apache.spark.streaming.receiver.Receiver ...@@ -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 * To run this on your local machine, you need to first run a Netcat server
* `$ nc -lk 9999` * `$ nc -lk 9999`
* and then run the example * 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 { object CustomReceiver {
def main(args: Array[String]) { def main(args: Array[String]) {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment