Repository: flink Updated Branches: refs/heads/release-1.4 9b59e6ff5 -> e776215bc
[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/e776215b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e776215b Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e776215b Branch: refs/heads/release-1.4 Commit: e776215bc451a8a78ef844bf70b7eeec31999a10 Parents: 9b59e6f Author: yanghua <[email protected]> Authored: Sat Apr 28 11:01:38 2018 +0800 Committer: zentol <[email protected]> Committed: Wed May 2 19:02:59 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/e776215b/docs/dev/table/common.md ---------------------------------------------------------------------- diff --git a/docs/dev/table/common.md b/docs/dev/table/common.md index f562f6a..7b4717e 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)
