diff options
author | Namit Katariya <katariya.namit@gmail.com> | 2015-08-05 01:07:33 -0700 |
---|---|---|
committer | Tathagata Das <tathagata.das1565@gmail.com> | 2015-08-05 01:07:51 -0700 |
commit | 6306019ff126ba064919e70d244fa43dd6349cdf (patch) | |
tree | 10a824540edcc96d85ffc95c004fb8bff4361f5e /docs | |
parent | 7fa41953536d60259dff8ee83e5a3b0050abc9ca (diff) | |
download | spark-6306019ff126ba064919e70d244fa43dd6349cdf.tar.gz spark-6306019ff126ba064919e70d244fa43dd6349cdf.tar.bz2 spark-6306019ff126ba064919e70d244fa43dd6349cdf.zip |
[SPARK-9601] [DOCS] Fix JavaPairDStream signature for stream-stream and windowed join in streaming guide doc
Author: Namit Katariya <katariya.namit@gmail.com>
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
(cherry picked from commit 1bf608b5ef1e6e2ae4325e13c2bd5e34db62450f)
Signed-off-by: Tathagata Das <tathagata.das1565@gmail.com>
Diffstat (limited to 'docs')
-rw-r--r-- | docs/streaming-programming-guide.md | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/docs/streaming-programming-guide.md b/docs/streaming-programming-guide.md index 4663b3f14c..dbfdb619f8 100644 --- a/docs/streaming-programming-guide.md +++ b/docs/streaming-programming-guide.md @@ -1141,7 +1141,7 @@ val joinedStream = stream1.join(stream2) {% highlight java %} JavaPairDStream<String, String> stream1 = ... JavaPairDStream<String, String> stream2 = ... -JavaPairDStream<String, String> joinedStream = stream1.join(stream2); +JavaPairDStream<String, Tuple2<String, String>> joinedStream = stream1.join(stream2); {% endhighlight %} </div> <div data-lang="python" markdown="1"> @@ -1166,7 +1166,7 @@ val joinedStream = windowedStream1.join(windowedStream2) {% highlight java %} JavaPairDStream<String, String> windowedStream1 = stream1.window(Durations.seconds(20)); JavaPairDStream<String, String> windowedStream2 = stream2.window(Durations.minutes(1)); -JavaPairDStream<String, String> joinedStream = windowedStream1.join(windowedStream2); +JavaPairDStream<String, Tuple2<String, String>> joinedStream = windowedStream1.join(windowedStream2); {% endhighlight %} </div> <div data-lang="python" markdown="1"> |