You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@bahir.apache.org by lr...@apache.org on 2016/06/10 15:24:10 UTC
[31/50] [abbrv] bahir git commit: [SPARK-13177][EXAMPLES] Update
ActorWordCount example to not directly use low level linked list as it is
deprecated.
[SPARK-13177][EXAMPLES] Update ActorWordCount example to not directly use low level linked list as it is deprecated.
Author: sachin aggarwal <di...@gmail.com>
Closes #11113 from agsachin/master.
Project: http://git-wip-us.apache.org/repos/asf/bahir/repo
Commit: http://git-wip-us.apache.org/repos/asf/bahir/commit/898980d0
Tree: http://git-wip-us.apache.org/repos/asf/bahir/tree/898980d0
Diff: http://git-wip-us.apache.org/repos/asf/bahir/diff/898980d0
Branch: refs/heads/master
Commit: 898980d0674877147598b0ce9b93b3e5386ffa2d
Parents: 42d6c06
Author: sachin aggarwal <di...@gmail.com>
Authored: Tue Feb 9 08:52:58 2016 +0000
Committer: Sean Owen <so...@cloudera.com>
Committed: Tue Feb 9 08:52:58 2016 +0000
----------------------------------------------------------------------
.../spark/examples/streaming/akka/ActorWordCount.scala | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/bahir/blob/898980d0/streaming-akka/examples/src/main/scala/org/apache/spark/examples/streaming/akka/ActorWordCount.scala
----------------------------------------------------------------------
diff --git a/streaming-akka/examples/src/main/scala/org/apache/spark/examples/streaming/akka/ActorWordCount.scala b/streaming-akka/examples/src/main/scala/org/apache/spark/examples/streaming/akka/ActorWordCount.scala
index 8e88987..9f7c7d5 100644
--- a/streaming-akka/examples/src/main/scala/org/apache/spark/examples/streaming/akka/ActorWordCount.scala
+++ b/streaming-akka/examples/src/main/scala/org/apache/spark/examples/streaming/akka/ActorWordCount.scala
@@ -18,7 +18,7 @@
// scalastyle:off println
package org.apache.spark.examples.streaming
-import scala.collection.mutable.LinkedList
+import scala.collection.mutable.LinkedHashSet
import scala.reflect.ClassTag
import scala.util.Random
@@ -39,7 +39,7 @@ case class UnsubscribeReceiver(receiverActor: ActorRef)
class FeederActor extends Actor {
val rand = new Random()
- var receivers: LinkedList[ActorRef] = new LinkedList[ActorRef]()
+ val receivers = new LinkedHashSet[ActorRef]()
val strings: Array[String] = Array("words ", "may ", "count ")
@@ -63,11 +63,11 @@ class FeederActor extends Actor {
def receive: Receive = {
case SubscribeReceiver(receiverActor: ActorRef) =>
println("received subscribe from %s".format(receiverActor.toString))
- receivers = LinkedList(receiverActor) ++ receivers
+ receivers += receiverActor
case UnsubscribeReceiver(receiverActor: ActorRef) =>
println("received unsubscribe from %s".format(receiverActor.toString))
- receivers = receivers.dropWhile(x => x eq receiverActor)
+ receivers -= receiverActor
}
}