You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2015/04/17 13:08:58 UTC

flink git commit: [FLINK-1900] add missing '

Repository: flink
Updated Branches:
  refs/heads/master 10fc1d8d3 -> 26ce47f52


[FLINK-1900] add missing '


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/26ce47f5
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/26ce47f5
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/26ce47f5

Branch: refs/heads/master
Commit: 26ce47f52e7d533f069b18d13e2e01aa9e56a483
Parents: 10fc1d8
Author: FelixNeutatz <ne...@googlemail.com>
Authored: Fri Apr 17 10:31:18 2015 +0200
Committer: Aljoscha Krettek <al...@gmail.com>
Committed: Fri Apr 17 13:08:26 2015 +0200

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


http://git-wip-us.apache.org/repos/asf/flink/blob/26ce47f5/docs/table.md
----------------------------------------------------------------------
diff --git a/docs/table.md b/docs/table.md
index 5a40fe4..baf1aa9 100644
--- a/docs/table.md
+++ b/docs/table.md
@@ -55,7 +55,7 @@ import org.apache.flink.api.scala.table._
 case class WC(word: String, count: Int)
 val input = env.fromElements(WC("hello", 1), WC("hello", 1), WC("ciao", 1))
 val expr = input.toTable
-val result = expr.groupBy('word).select('word, 'count.sum as count).toSet[WC]
+val result = expr.groupBy('word).select('word, 'count.sum as 'count).toSet[WC]
 {% endhighlight %}
 
 The expression DSL uses Scala symbols to refer to field names and we use code generation to