You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by rm...@apache.org on 2016/08/08 12:53:24 UTC
flink git commit: [FLINK-4226] Typo: Define Keys using Field
Expressions example should use window and not reduce
Repository: flink
Updated Branches:
refs/heads/master 6a883776d -> 0e0c40d8a
[FLINK-4226] Typo: Define Keys using Field Expressions example should use window and not reduce
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0e0c40d8
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0e0c40d8
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0e0c40d8
Branch: refs/heads/master
Commit: 0e0c40d8a19ddc37d6cb5fd657cb7093470d1d1d
Parents: 6a88377
Author: Ahmad Ragab <Av...@gmail.com>
Authored: Sun Jul 17 00:38:33 2016 -0400
Committer: Robert Metzger <rm...@apache.org>
Committed: Mon Aug 8 14:52:54 2016 +0200
----------------------------------------------------------------------
docs/apis/common/index.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/0e0c40d8/docs/apis/common/index.md
----------------------------------------------------------------------
diff --git a/docs/apis/common/index.md b/docs/apis/common/index.md
index ea7c0af..05d87ce 100644
--- a/docs/apis/common/index.md
+++ b/docs/apis/common/index.md
@@ -528,7 +528,7 @@ val wordCounts = words.keyBy("word").window(/*window specification*/)
// or, as a case class, which is less typing
case class WC(word: String, count: Int)
val words: DataStream[WC] = // [...]
-val wordCounts = words.keyBy("word").reduce(/*window specification*/)
+val wordCounts = words.keyBy("word").window(/*window specification*/)
{% endhighlight %}
**Field Expression Syntax**: