aboutsummaryrefslogtreecommitdiff
path: root/examples
diff options
context:
space:
mode:
authorPrashant Sharma <prashant.s@imaginea.com>2013-01-25 14:34:38 +0530
committerPrashant Sharma <prashant.s@imaginea.com>2013-01-25 14:34:38 +0530
commit4496bf197bb1137cc1224d8e5cb5f55625dd5851 (patch)
tree48f1b80046e342b352e192d9ccc01dfd375135d6 /examples
parentd17065c4b565ec975a46c6d375998ef8ae7a32d5 (diff)
downloadspark-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.scala8
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)
}