Repository: flink Updated Branches: refs/heads/release-1.4 90acd785e -> b65ec3fb6
[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/b65ec3fb Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b65ec3fb Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b65ec3fb Branch: refs/heads/release-1.4 Commit: b65ec3fb61cb46bb240a86944b47e33d178943e6 Parents: 90acd78 Author: Jeff Zhang <[email protected]> Authored: Thu Jun 7 08:45:43 2018 +0800 Committer: Fabian Hueske <[email protected]> Committed: Thu Jun 7 21:57:39 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/b65ec3fb/docs/dev/table/common.md ---------------------------------------------------------------------- diff --git a/docs/dev/table/common.md b/docs/dev/table/common.md index 7b4717e..9af52c1 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'
