Repository: flink Updated Branches: refs/heads/release-1.5 e2cc37ddf -> 0465c6b61
[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/0465c6b6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0465c6b6 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0465c6b6 Branch: refs/heads/release-1.5 Commit: 0465c6b61b4f2d17a31498ab18c7c060b23364dc Parents: e2cc37d Author: Jeff Zhang <[email protected]> Authored: Thu Jun 7 08:45:43 2018 +0800 Committer: Fabian Hueske <[email protected]> Committed: Thu Jun 7 21:56:51 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/0465c6b6/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'
