diff options
| author | Santiago M. Mola <santi@mola.io> | 2014-09-20 15:05:03 -0700 |
|---|---|---|
| committer | Josh Rosen <joshrosen@apache.org> | 2014-09-20 15:05:03 -0700 |
| commit | c32c8538efca2124924920614e4dbe7ce90938f4 (patch) | |
| tree | bda5db01de0b0abc81c15790b977a3ea0992cb91 /docs/streaming-programming-guide.md | |
| parent | 78d4220fa0bf2f9ee663e34bbf3544a5313b02f0 (diff) | |
| download | spark-c32c8538efca2124924920614e4dbe7ce90938f4.tar.gz spark-c32c8538efca2124924920614e4dbe7ce90938f4.tar.bz2 spark-c32c8538efca2124924920614e4dbe7ce90938f4.zip | |
Fix Java example in Streaming Programming Guide
"val conf" was used instead of "SparkConf conf" in Java snippet.
Author: Santiago M. Mola <santi@mola.io>
Closes #2472 from smola/patch-1 and squashes the following commits:
5bfeb9b [Santiago M. Mola] Fix Java example in Streaming Programming Guide
Diffstat (limited to 'docs/streaming-programming-guide.md')
| -rw-r--r-- | docs/streaming-programming-guide.md | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/docs/streaming-programming-guide.md b/docs/streaming-programming-guide.md index 41f170580f..5c21e912ea 100644 --- a/docs/streaming-programming-guide.md +++ b/docs/streaming-programming-guide.md @@ -138,7 +138,7 @@ import org.apache.spark.streaming.api.java.*; import scala.Tuple2; // Create a local StreamingContext with two working thread and batch interval of 1 second -val conf = new SparkConf().setMaster("local[2]").setAppName("NetworkWordCount") +SparkConf conf = new SparkConf().setMaster("local[2]").setAppName("NetworkWordCount") JavaStreamingContext jssc = new JavaStreamingContext(conf, new Duration(1000)) {% endhighlight %} |