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:33 -0700 |
| commit | 1bf608b5ef1e6e2ae4325e13c2bd5e34db62450f (patch) | |
| tree | 10a824540edcc96d85ffc95c004fb8bff4361f5e /docs/streaming-programming-guide.md | |
| parent | 6d8a6e4161176e391514153d7535da14b52194be (diff) | |
| download | spark-1bf608b5ef1e6e2ae4325e13c2bd5e34db62450f.tar.gz spark-1bf608b5ef1e6e2ae4325e13c2bd5e34db62450f.tar.bz2 spark-1bf608b5ef1e6e2ae4325e13c2bd5e34db62450f.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
Diffstat (limited to 'docs/streaming-programming-guide.md')
| -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"> |