diff options
author | Tathagata Das <tathagata.das1565@gmail.com> | 2014-01-16 14:44:02 -0800 |
---|---|---|
committer | Tathagata Das <tathagata.das1565@gmail.com> | 2014-01-16 14:44:02 -0800 |
commit | 11e6534d9251fa81798bdeb9cc764ce4bb83d616 (patch) | |
tree | 9e38bc26a9d89311de38f7c52bd82d57c9baf741 /examples/src/main/scala/org | |
parent | c06a307ca22901839df00d25fe623f6faa6af17e (diff) | |
download | spark-11e6534d9251fa81798bdeb9cc764ce4bb83d616.tar.gz spark-11e6534d9251fa81798bdeb9cc764ce4bb83d616.tar.bz2 spark-11e6534d9251fa81798bdeb9cc764ce4bb83d616.zip |
Updated java API docs for streaming, along with very minor changes in the code examples.
Diffstat (limited to 'examples/src/main/scala/org')
-rw-r--r-- | examples/src/main/scala/org/apache/spark/streaming/examples/ActorWordCount.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/examples/src/main/scala/org/apache/spark/streaming/examples/ActorWordCount.scala b/examples/src/main/scala/org/apache/spark/streaming/examples/ActorWordCount.scala index 57e1b1f806..5a4aa7f3a2 100644 --- a/examples/src/main/scala/org/apache/spark/streaming/examples/ActorWordCount.scala +++ b/examples/src/main/scala/org/apache/spark/streaming/examples/ActorWordCount.scala @@ -88,7 +88,7 @@ extends Actor with Receiver { override def preStart = remotePublisher ! SubscribeReceiver(context.self) def receive = { - case msg ⇒ context.parent ! pushBlock(msg.asInstanceOf[T]) + case msg ⇒ pushBlock(msg.asInstanceOf[T]) } override def postStop() = remotePublisher ! UnsubscribeReceiver(context.self) |