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 <[email protected]> Authored: Fri Apr 17 10:31:18 2015 +0200 Committer: Aljoscha Krettek <[email protected]> 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
