From c5d06e59faccc6861960ad65f2535e1bb9d56793 Mon Sep 17 00:00:00 2001
From: Ahmad Ragab <Averroes2006@gmail.com>
Date: Sun, 17 Jul 2016 00:38:33 -0400
Subject: [PATCH] [FLINK-4226] Typo: Define Keys using Field Expressions
 example should use window and not reduce

---
 docs/apis/common/index.md | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/docs/apis/common/index.md b/docs/apis/common/index.md
index ea7c0af5a3a6c..05d87ce850167 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**: