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 is running on.
To run this example locally, you may run Feeder Actor as
$ ./bin/run-example org.apache.spark.streaming.examples.FeederActor 127.0.1.1 9999
and then run the example
$ ./bin/run-example org.apache.spark.streaming.examples.ActorWordCount local[2] 127.0.1.1 9999
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 is running on.
To run this example locally, you may run Feeder Actor as
$ ./bin/run-example org.apache.spark.streaming.examples.FeederActor 127.0.1.1 9999
and then run the example$ ./bin/run-example org.apache.spark.streaming.examples.ActorWordCount local[2] 127.0.1.1 9999