Skip to content
Snippets Groups Projects
Commit d9ba4d27 authored by sachin aggarwal's avatar sachin aggarwal Committed by Sean Owen
Browse files

[SPARK-13177][EXAMPLES] Update ActorWordCount example to not directly use low...

[SPARK-13177][EXAMPLES] Update ActorWordCount example to not directly use low level linked list as it is deprecated.

Author: sachin aggarwal <different.sachin@gmail.com>

Closes #11113 from agsachin/master.
parent c882ec57
No related branches found
No related tags found
No related merge requests found
...@@ -18,7 +18,7 @@ ...@@ -18,7 +18,7 @@
// scalastyle:off println // scalastyle:off println
package org.apache.spark.examples.streaming package org.apache.spark.examples.streaming
import scala.collection.mutable.LinkedList import scala.collection.mutable.LinkedHashSet
import scala.reflect.ClassTag import scala.reflect.ClassTag
import scala.util.Random import scala.util.Random
...@@ -39,7 +39,7 @@ case class UnsubscribeReceiver(receiverActor: ActorRef) ...@@ -39,7 +39,7 @@ case class UnsubscribeReceiver(receiverActor: ActorRef)
class FeederActor extends Actor { class FeederActor extends Actor {
val rand = new Random() val rand = new Random()
var receivers: LinkedList[ActorRef] = new LinkedList[ActorRef]() val receivers = new LinkedHashSet[ActorRef]()
val strings: Array[String] = Array("words ", "may ", "count ") val strings: Array[String] = Array("words ", "may ", "count ")
...@@ -63,11 +63,11 @@ class FeederActor extends Actor { ...@@ -63,11 +63,11 @@ class FeederActor extends Actor {
def receive: Receive = { def receive: Receive = {
case SubscribeReceiver(receiverActor: ActorRef) => case SubscribeReceiver(receiverActor: ActorRef) =>
println("received subscribe from %s".format(receiverActor.toString)) println("received subscribe from %s".format(receiverActor.toString))
receivers = LinkedList(receiverActor) ++ receivers receivers += receiverActor
case UnsubscribeReceiver(receiverActor: ActorRef) => case UnsubscribeReceiver(receiverActor: ActorRef) =>
println("received unsubscribe from %s".format(receiverActor.toString)) println("received unsubscribe from %s".format(receiverActor.toString))
receivers = receivers.dropWhile(x => x eq receiverActor) receivers -= receiverActor
} }
} }
......
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