Repository: flink Updated Branches: refs/heads/release-1.5 dd5639164 -> 108d405ae
[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/108d405a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/108d405a Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/108d405a Branch: refs/heads/release-1.5 Commit: 108d405aecbe14edd8f919e28d260a8f4fc513ee Parents: dd56391 Author: yanghua <[email protected]> Authored: Sat Apr 28 11:01:38 2018 +0800 Committer: zentol <[email protected]> Committed: Wed May 2 19:01:54 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/108d405a/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)
