You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/05/02 17:01:49 UTC
flink git commit: [FLINK-9119][table][docs] Fix example code error in
Concepts & Common API
Repository: flink
Updated Branches:
refs/heads/master ac9156ade -> 0973e34b3
[FLINK-9119][table][docs] Fix example code error in Concepts & Common API
This closes #5935.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0973e34b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0973e34b
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0973e34b
Branch: refs/heads/master
Commit: 0973e34b3c596c23df11335b3b8e657e85dd12e6
Parents: ac9156a
Author: yanghua <ya...@gmail.com>
Authored: Sat Apr 28 11:01:38 2018 +0800
Committer: zentol <ch...@apache.org>
Committed: Wed May 2 19:01:46 2018 +0200
----------------------------------------------------------------------
docs/dev/table/common.md | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/0973e34b/docs/dev/table/common.md
----------------------------------------------------------------------
diff --git a/docs/dev/table/common.md b/docs/dev/table/common.md
index 3e3965a..15141fe 100644
--- a/docs/dev/table/common.md
+++ b/docs/dev/table/common.md
@@ -173,7 +173,7 @@ A `Table` is registered in a `TableEnvironment` as follows:
StreamTableEnvironment tableEnv = TableEnvironment.getTableEnvironment(env);
// Table is the result of a simple projection query
-Table projTable = tableEnv.scan("X").project(...);
+Table projTable = tableEnv.scan("X").select(...);
// register the Table projTable as table "projectedX"
tableEnv.registerTable("projectedTable", projTable);
@@ -186,7 +186,7 @@ tableEnv.registerTable("projectedTable", projTable);
val tableEnv = TableEnvironment.getTableEnvironment(env)
// Table is the result of a simple projection query
-val projTable: Table = tableEnv.scan("X").project(...)
+val projTable: Table = tableEnv.scan("X").select(...)
// register the Table projTable as table "projectedX"
tableEnv.registerTable("projectedTable", projTable)