Repository: spark Updated Branches: refs/heads/master 5728aa558 -> 2d34183b2
[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.w...@gmail.com> Closes #13388 from mawise/fix_docs_java_streaming_example. Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/2d34183b Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/2d34183b Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/2d34183b Branch: refs/heads/master Commit: 2d34183b273af1125181f04c49725efc2fa351af Parents: 5728aa5 Author: Matthew Wise <matthew.rs.w...@gmail.com> Authored: Mon May 30 09:12:02 2016 -0500 Committer: Sean Owen <so...@cloudera.com> Committed: Mon May 30 09:12:02 2016 -0500 ---------------------------------------------------------------------- docs/streaming-kafka-integration.md | 2 +- docs/streaming-programming-guide.md | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/2d34183b/docs/streaming-kafka-integration.md ---------------------------------------------------------------------- diff --git a/docs/streaming-kafka-integration.md b/docs/streaming-kafka-integration.md index 0f1e322..e0d3f4f 100644 --- a/docs/streaming-kafka-integration.md +++ b/docs/streaming-kafka-integration.md @@ -111,7 +111,7 @@ Next, we discuss how to use this approach in your streaming application. <div data-lang="java" markdown="1"> import org.apache.spark.streaming.kafka.*; - JavaPairReceiverInputDStream<String, String> directKafkaStream = + JavaPairInputDStream<String, String> directKafkaStream = KafkaUtils.createDirectStream(streamingContext, [key class], [value class], [key decoder class], [value decoder class], [map of Kafka parameters], [set of topics to consume]); http://git-wip-us.apache.org/repos/asf/spark/blob/2d34183b/docs/streaming-programming-guide.md ---------------------------------------------------------------------- diff --git a/docs/streaming-programming-guide.md b/docs/streaming-programming-guide.md index d7eafff..6550fcc 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 --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org
