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-kafka-integration.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-kafka-integration.md')
-rw-r--r-- | docs/streaming-kafka-integration.md | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/docs/streaming-kafka-integration.md b/docs/streaming-kafka-integration.md index 0f1e32212e..e0d3f4f69b 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]); |