From 2d34183b273af1125181f04c49725efc2fa351af Mon Sep 17 00:00:00 2001
From: Matthew Wise <matthew.rs.wise@gmail.com>
Date: Mon, 30 May 2016 09:12:02 -0500
Subject: [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.
---
 docs/streaming-kafka-integration.md | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

(limited to 'docs/streaming-kafka-integration.md')

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]);
-- 
cgit v1.2.3