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/java/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/java/org')
| -rw-r--r-- | examples/src/main/java/org/apache/spark/streaming/examples/JavaQueueStream.java | 3 |
1 files changed, 1 insertions, 2 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( |