spark-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sro...@apache.org
Subject spark git commit: [DOCS] fix example code issues in documentation
Date Mon, 30 May 2016 14:12:09 GMT
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.wise@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.wise@gmail.com>
Authored: Mon May 30 09:12:02 2016 -0500
Committer: Sean Owen <sowen@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-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org


Mime
View raw message