flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rmetz...@apache.org
Subject flink git commit: [FLINK-4226] Typo: Define Keys using Field Expressions example should use window and not reduce
Date Mon, 08 Aug 2016 12:53:24 GMT
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 <Averroes2006@gmail.com>
Authored: Sun Jul 17 00:38:33 2016 -0400
Committer: Robert Metzger <rmetzger@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**:


Mime
View raw message