You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by le...@apache.org on 2022/11/14 06:13:27 UTC
[flink] branch master updated: [hotfix][docs][table] Minor improvements for versioned table example
This is an automated email from the ASF dual-hosted git repository.
leonard pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 7ceca180717 [hotfix][docs][table] Minor improvements for versioned table example
7ceca180717 is described below
commit 7ceca1807177c2a572ab4fb402e1435e3f7df232
Author: lincoln lee <li...@gmail.com>
AuthorDate: Mon Nov 14 14:13:18 2022 +0800
[hotfix][docs][table] Minor improvements for versioned table example
This closes #21308.
---
docs/content/docs/dev/table/concepts/versioned_tables.md | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/docs/content/docs/dev/table/concepts/versioned_tables.md b/docs/content/docs/dev/table/concepts/versioned_tables.md
index 22359f20451..4cf494898c3 100644
--- a/docs/content/docs/dev/table/concepts/versioned_tables.md
+++ b/docs/content/docs/dev/table/concepts/versioned_tables.md
@@ -127,6 +127,7 @@ The `JSON` format does not support native changelog semantics, so Flink can only
+(INSERT) 09:00:00 Euro 114
+(INSERT) 09:00:00 USD 1
+(INSERT) 11:15:00 Euro 119
++(INSERT) 11:45:00 Pounds 107
+(INSERT) 11:49:00 Pounds 108
```
@@ -152,9 +153,9 @@ WHERE rownum = 1;
+(INSERT) 09:00:00 Yen 102
+(INSERT) 09:00:00 Euro 114
+(INSERT) 09:00:00 USD 1
-+(UPDATE_AFTER) 10:45:00 Euro 116
+(UPDATE_AFTER) 11:15:00 Euro 119
-+(INSERT) 11:49:00 Pounds 108
++(INSERT) 11:45:00 Pounds 107
++(UPDATE_AFTER) 11:49:00 Pounds 108
```
Flink has a special optimization step that will efficiently transform this query into a versioned