aboutsummaryrefslogtreecommitdiff
path: root/examples
diff options
context:
space:
mode:
authorTathagata Das <tathagata.das1565@gmail.com>2014-01-16 14:44:02 -0800
committerTathagata Das <tathagata.das1565@gmail.com>2014-01-16 14:44:02 -0800
commit11e6534d9251fa81798bdeb9cc764ce4bb83d616 (patch)
tree9e38bc26a9d89311de38f7c52bd82d57c9baf741 /examples
parentc06a307ca22901839df00d25fe623f6faa6af17e (diff)
downloadspark-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')
-rw-r--r--examples/src/main/java/org/apache/spark/streaming/examples/JavaQueueStream.java3
-rw-r--r--examples/src/main/scala/org/apache/spark/streaming/examples/ActorWordCount.scala2
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)