diff options
| author | Clément MATHIEU <clement@unportant.info> | 2014-07-03 18:31:18 -0700 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2014-07-03 18:31:18 -0700 |
| commit | fdc4c112e7c2ac585d108d03209a642aa8bab7c8 (patch) | |
| tree | fb6331b1b15b6a076e43a2c947062b80a0039452 /docs | |
| parent | d4c30cd9918e18dde2a52909e36eaef6eb5996ab (diff) | |
| download | spark-fdc4c112e7c2ac585d108d03209a642aa8bab7c8.tar.gz spark-fdc4c112e7c2ac585d108d03209a642aa8bab7c8.tar.bz2 spark-fdc4c112e7c2ac585d108d03209a642aa8bab7c8.zip | |
Streaming programming guide typos
Fix a bad Java code sample and a broken link in the streaming programming guide.
Author: Clément MATHIEU <clement@unportant.info>
Closes #1286 from cykl/streaming-programming-guide-typos and squashes the following commits:
b0908cb [Clément MATHIEU] Fix broken URL
9d3c535 [Clément MATHIEU] Spark streaming requires at least two working threads (scala version was OK)
Diffstat (limited to 'docs')
| -rw-r--r-- | docs/streaming-programming-guide.md | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/docs/streaming-programming-guide.md b/docs/streaming-programming-guide.md index ce8e58d64a..90a0eef60c 100644 --- a/docs/streaming-programming-guide.md +++ b/docs/streaming-programming-guide.md @@ -148,7 +148,7 @@ import org.apache.spark.streaming.*; import org.apache.spark.streaming.api.java.*; import scala.Tuple2; // Create a StreamingContext with a local master -JavaStreamingContext jssc = new JavaStreamingContext("local", "JavaNetworkWordCount", new Duration(1000)) +JavaStreamingContext jssc = new JavaStreamingContext("local[2]", "JavaNetworkWordCount", new Duration(1000)) {% endhighlight %} Using this context, we then create a new DStream @@ -216,7 +216,7 @@ jssc.awaitTermination(); // Wait for the computation to terminate {% endhighlight %} The complete code can be found in the Spark Streaming example -[JavaNetworkWordCount]({{site.SPARK_GITHUB_URL}}/blob/master/examples/src/main/java/index.html?org/apache/spark/examples/streaming/JavaNetworkWordCount.java). +[JavaNetworkWordCount]({{site.SPARK_GITHUB_URL}}/blob/master/examples/src/main/java/org/apache/spark/examples/streaming/JavaNetworkWordCount.java). <br> </div> |