You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fh...@apache.org on 2016/11/23 20:15:34 UTC
[2/3] flink git commit: [hotfix][docs] Stream joins don't support
tuple position keys
[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/074b4e60
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/074b4e60
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/074b4e60
Branch: refs/heads/release-1.1
Commit: 074b4e60ae0ca6b9e2f0dc064ec6cbaf5543b199
Parents: efbd293
Author: Robert Metzger <rm...@apache.org>
Authored: Fri Nov 4 15:41:06 2016 +0100
Committer: Fabian Hueske <fh...@apache.org>
Committed: Wed Nov 23 21:08:29 2016 +0100
----------------------------------------------------------------------
docs/apis/streaming/index.md | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/074b4e60/docs/apis/streaming/index.md
----------------------------------------------------------------------
diff --git a/docs/apis/streaming/index.md b/docs/apis/streaming/index.md
index f6fbbd5..806ae4b 100644
--- a/docs/apis/streaming/index.md
+++ b/docs/apis/streaming/index.md
@@ -409,7 +409,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 %}
@@ -758,7 +758,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 %}