You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fh...@apache.org on 2018/06/07 19:56:28 UTC
flink git commit: [hotfix] [docs] Fix Scala code examples for Table
API and SQL.
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 <zj...@apache.org>
Authored: Thu Jun 7 08:45:43 2018 +0800
Committer: Fabian Hueske <fh...@apache.org>
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'