[hotfix][docs] Stream joins don't support tuple position keys
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3458a661 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3458a661 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/3458a661 Branch: refs/heads/master Commit: 3458a6615cf1db66f32650bbaae2841b570fa647 Parents: 74e0971 Author: Robert Metzger <[email protected]> Authored: Fri Nov 4 15:41:06 2016 +0100 Committer: Fabian Hueske <[email protected]> Committed: Wed Nov 23 18:35:44 2016 +0100 ---------------------------------------------------------------------- docs/dev/datastream_api.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/3458a661/docs/dev/datastream_api.md ---------------------------------------------------------------------- diff --git a/docs/dev/datastream_api.md b/docs/dev/datastream_api.md index 4c81d63..57d2e4b 100644 --- a/docs/dev/datastream_api.md +++ b/docs/dev/datastream_api.md @@ -401,7 +401,7 @@ dataStream.union(otherStream1, otherStream2, ...); <p>Join two data streams on a given key and a common window.</p> {% highlight java %} dataStream.join(otherStream) - .where(0).equalTo(1) + .where(<key selector>).equalTo(<key selector>) .window(TumblingEventTimeWindows.of(Time.seconds(3))) .apply (new JoinFunction () {...}); {% endhighlight %} @@ -750,7 +750,7 @@ dataStream.union(otherStream1, otherStream2, ...) <p>Join two data streams on a given key and a common window.</p> {% highlight scala %} dataStream.join(otherStream) - .where(0).equalTo(1) + .where(<key selector>).equalTo(<key selector>) .window(TumblingEventTimeWindows.of(Time.seconds(3))) .apply { ... } {% endhighlight %}
