diff options
| author | Matthew Wise <matthew.rs.wise@gmail.com> | 2016-05-30 09:12:02 -0500 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2016-05-30 09:12:02 -0500 |
| commit | 2d34183b273af1125181f04c49725efc2fa351af (patch) | |
| tree | 8da6306d8eaa3a7cd4b95b552614b10af083c699 /docs/streaming-programming-guide.md | |
| parent | 5728aa558e44f056f3e5a7f8726ab174d3830103 (diff) | |
| download | spark-2d34183b273af1125181f04c49725efc2fa351af.tar.gz spark-2d34183b273af1125181f04c49725efc2fa351af.tar.bz2 spark-2d34183b273af1125181f04c49725efc2fa351af.zip | |
[DOCS] fix example code issues in documentation
## What changes were proposed in this pull request?
Fixed broken java code examples in streaming documentation
Attn: tdas
Author: Matthew Wise <matthew.rs.wise@gmail.com>
Closes #13388 from mawise/fix_docs_java_streaming_example.
Diffstat (limited to 'docs/streaming-programming-guide.md')
| -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 d7eafff38f..6550fcc052 100644 --- a/docs/streaming-programming-guide.md +++ b/docs/streaming-programming-guide.md @@ -145,8 +145,8 @@ import org.apache.spark.streaming.api.java.*; import scala.Tuple2; // Create a local StreamingContext with two working thread and batch interval of 1 second -SparkConf conf = new SparkConf().setMaster("local[2]").setAppName("NetworkWordCount") -JavaStreamingContext jssc = new JavaStreamingContext(conf, Durations.seconds(1)) +SparkConf conf = new SparkConf().setMaster("local[2]").setAppName("NetworkWordCount"); +JavaStreamingContext jssc = new JavaStreamingContext(conf, Durations.seconds(1)); {% endhighlight %} Using this context, we can create a DStream that represents streaming data from a TCP |