Skip to content

Commit 1bf608b

Browse files
namitktdas
authored andcommitted
[SPARK-9601] [DOCS] Fix JavaPairDStream signature for stream-stream and windowed join in streaming guide doc
Author: Namit Katariya <[email protected]> Closes #7935 from namitk/SPARK-9601 and squashes the following commits: 03b5784 [Namit Katariya] [SPARK-9601] Fix signature of JavaPairDStream for stream-stream and windowed join in streaming guide doc
1 parent 6d8a6e4 commit 1bf608b

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

docs/streaming-programming-guide.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1141,7 +1141,7 @@ val joinedStream = stream1.join(stream2)
11411141
{% highlight java %}
11421142
JavaPairDStream<String, String> stream1 = ...
11431143
JavaPairDStream<String, String> stream2 = ...
1144-
JavaPairDStream<String, String> joinedStream = stream1.join(stream2);
1144+
JavaPairDStream<String, Tuple2<String, String>> joinedStream = stream1.join(stream2);
11451145
{% endhighlight %}
11461146
</div>
11471147
<div data-lang="python" markdown="1">
@@ -1166,7 +1166,7 @@ val joinedStream = windowedStream1.join(windowedStream2)
11661166
{% highlight java %}
11671167
JavaPairDStream<String, String> windowedStream1 = stream1.window(Durations.seconds(20));
11681168
JavaPairDStream<String, String> windowedStream2 = stream2.window(Durations.minutes(1));
1169-
JavaPairDStream<String, String> joinedStream = windowedStream1.join(windowedStream2);
1169+
JavaPairDStream<String, Tuple2<String, String>> joinedStream = windowedStream1.join(windowedStream2);
11701170
{% endhighlight %}
11711171
</div>
11721172
<div data-lang="python" markdown="1">

0 commit comments

Comments
 (0)