ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Improved document comment in example

Browse source
This commit is contained in:
Prashant Sharma 2013-01-25 14:34:38 +05:30
parent d17065c4b5
commit 4496bf197b
1 changed files with 7 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
examples/src/main/scala/spark/streaming/examples/ActorWordCount.scala
View file

@ -84,12 +84,18 @@ class SampleActorReceiver[T: ClassManifest](urlOfPublisher: String)
/** /**
* A sample word count program demonstrating the use of plugging in * A sample word count program demonstrating the use of plugging in
* Actor as Receiver * 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 { object ActorWordCount {
def main(args: Array[String]) { def main(args: Array[String]) {
if (args.length < 3) { if (args.length < 3) {
System.err.println( System.err.println(
"Usage: ActorWordCount <master> <host> <port>" + "Usage: ActorWordCount <master> <hostname> <port>" +
"In local mode, <master> should be 'local[n]' with n > 1") "In local mode, <master> should be 'local[n]' with n > 1")
System.exit(1) System.exit(1)
} }