Repository: flink Updated Branches: refs/heads/master c4a7a42a1 -> 75d74d251
[hotfix] [docs] Fix Scala code examples for Table API and SQL. This closes #6131. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/75d74d25 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/75d74d25 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/75d74d25 Branch: refs/heads/master Commit: 75d74d2514662c8d398667d1e24fe97a31bfe519 Parents: c4a7a42 Author: Jeff Zhang <[email protected]> Authored: Thu Jun 7 08:45:43 2018 +0800 Committer: Fabian Hueske <[email protected]> Committed: Thu Jun 7 21:55:13 2018 +0200 ---------------------------------------------------------------------- docs/dev/table/common.md | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/75d74d25/docs/dev/table/common.md ---------------------------------------------------------------------- diff --git a/docs/dev/table/common.md b/docs/dev/table/common.md index 15141fe..146d1a6 100644 --- a/docs/dev/table/common.md +++ b/docs/dev/table/common.md @@ -365,9 +365,9 @@ val tableEnv = TableEnvironment.getTableEnvironment(env) // register Orders table // scan registered Orders table -Table orders = tableEnv.scan("Orders") +val orders = tableEnv.scan("Orders") // compute revenue for all customers from France -Table revenue = orders +val revenue = orders .filter('cCountry === "FRANCE") .groupBy('cID, 'cName) .select('cID, 'cName, 'revenue.sum AS 'revSum) @@ -419,7 +419,7 @@ val tableEnv = TableEnvironment.getTableEnvironment(env) // register Orders table // compute revenue for all customers from France -Table revenue = tableEnv.sqlQuery(""" +val revenue = tableEnv.sqlQuery(""" |SELECT cID, cName, SUM(revenue) AS revSum |FROM Orders |WHERE cCountry = 'FRANCE'
