You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by sr...@apache.org on 2016/02/09 09:53:00 UTC
spark git commit: [SPARK-13177][EXAMPLES] Update ActorWordCount
example to not directly use low level linked list as it is deprecated.
Repository: spark
Updated Branches:
refs/heads/master c882ec57d -> d9ba4d27f
[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/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/d9ba4d27
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/d9ba4d27
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/d9ba4d27
Branch: refs/heads/master
Commit: d9ba4d27f4d324a7055b9b914c75d176f3e2f71d
Parents: c882ec5
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
----------------------------------------------------------------------
.../org/apache/spark/examples/streaming/ActorWordCount.scala | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/d9ba4d27/examples/src/main/scala/org/apache/spark/examples/streaming/ActorWordCount.scala
----------------------------------------------------------------------
diff --git a/examples/src/main/scala/org/apache/spark/examples/streaming/ActorWordCount.scala b/examples/src/main/scala/org/apache/spark/examples/streaming/ActorWordCount.scala
index 8e88987..9f7c7d5 100644
--- a/examples/src/main/scala/org/apache/spark/examples/streaming/ActorWordCount.scala
+++ b/examples/src/main/scala/org/apache/spark/examples/streaming/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
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org