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 <[email protected]> Authored: Sat Apr 28 11:01:38 2018 +0800 Committer: zentol <[email protected]> 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)
