diff options
author | Prashant Sharma <prashant.s@imaginea.com> | 2013-01-25 14:34:38 +0530 |
---|---|---|
committer | Prashant Sharma <prashant.s@imaginea.com> | 2013-01-25 14:34:38 +0530 |
commit | 4496bf197bb1137cc1224d8e5cb5f55625dd5851 (patch) | |
tree | 48f1b80046e342b352e192d9ccc01dfd375135d6 /examples | |
parent | d17065c4b565ec975a46c6d375998ef8ae7a32d5 (diff) | |
download | spark-4496bf197bb1137cc1224d8e5cb5f55625dd5851.tar.gz spark-4496bf197bb1137cc1224d8e5cb5f55625dd5851.tar.bz2 spark-4496bf197bb1137cc1224d8e5cb5f55625dd5851.zip |
Improved document comment in example
Diffstat (limited to 'examples')
-rw-r--r-- | examples/src/main/scala/spark/streaming/examples/ActorWordCount.scala | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/examples/src/main/scala/spark/streaming/examples/ActorWordCount.scala b/examples/src/main/scala/spark/streaming/examples/ActorWordCount.scala index c3d3755953..0ffa45a4c6 100644 --- a/examples/src/main/scala/spark/streaming/examples/ActorWordCount.scala +++ b/examples/src/main/scala/spark/streaming/examples/ActorWordCount.scala @@ -84,12 +84,18 @@ class SampleActorReceiver[T: ClassManifest](urlOfPublisher: String) /** * A sample word count program demonstrating the use of plugging in * Actor as Receiver + * Usage: ActorWordCount <master> <hostname> <port> + * <master> is the Spark master URL. In local mode, <master> should be 'local[n]' with n > 1. + * <hostname> and <port> describe the AkkaSystem that Spark Sample feeder would work on. + * + * and then run the example + * `$ ./run spark.streaming.examples.ActorWordCount local[2] 127.0.1.1 9999` */ object ActorWordCount { def main(args: Array[String]) { if (args.length < 3) { System.err.println( - "Usage: ActorWordCount <master> <host> <port>" + + "Usage: ActorWordCount <master> <hostname> <port>" + "In local mode, <master> should be 'local[n]' with n > 1") System.exit(1) } |