diff options
author | Patrick Wendell <pwendell@gmail.com> | 2014-01-19 10:29:54 -0800 |
---|---|---|
committer | Patrick Wendell <pwendell@gmail.com> | 2014-01-19 10:29:54 -0800 |
commit | 256a3553c447db0865ea8807a8fdbccb66a97b28 (patch) | |
tree | 87232ebd2152d1a8b40469c351360cd82d80a2b0 /examples | |
parent | fe8a3546f40394466a41fc750cb60f6fc73d8bbb (diff) | |
parent | 11e6534d9251fa81798bdeb9cc764ce4bb83d616 (diff) | |
download | spark-256a3553c447db0865ea8807a8fdbccb66a97b28.tar.gz spark-256a3553c447db0865ea8807a8fdbccb66a97b28.tar.bz2 spark-256a3553c447db0865ea8807a8fdbccb66a97b28.zip |
Merge pull request #458 from tdas/docs-update
Updated java API docs for streaming, along with very minor changes in the code examples.
Docs updated for:
Scala: StreamingContext, DStream, PairDStreamFunctions
Java: JavaStreamingContext, JavaDStream, JavaPairDStream
Example updated:
JavaQueueStream: Not use deprecated method
ActorWordCount: Use the public interface the right way.
Diffstat (limited to 'examples')
-rw-r--r-- | examples/src/main/java/org/apache/spark/streaming/examples/JavaQueueStream.java | 3 | ||||
-rw-r--r-- | examples/src/main/scala/org/apache/spark/streaming/examples/ActorWordCount.scala | 2 |
2 files changed, 2 insertions, 3 deletions
diff --git a/examples/src/main/java/org/apache/spark/streaming/examples/JavaQueueStream.java b/examples/src/main/java/org/apache/spark/streaming/examples/JavaQueueStream.java index 7ef9c6c8f4..e2d55f1a4e 100644 --- a/examples/src/main/java/org/apache/spark/streaming/examples/JavaQueueStream.java +++ b/examples/src/main/java/org/apache/spark/streaming/examples/JavaQueueStream.java @@ -58,10 +58,9 @@ public final class JavaQueueStream { } for (int i = 0; i < 30; i++) { - rddQueue.add(ssc.sc().parallelize(list)); + rddQueue.add(ssc.sparkContext().parallelize(list)); } - // Create the QueueInputDStream and use it do some processing JavaDStream<Integer> inputStream = ssc.queueStream(rddQueue); JavaPairDStream<Integer, Integer> mappedStream = inputStream.map( 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) |