This is an automated email from the ASF dual-hosted git repository.
ipolyzos pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git
The following commit(s) were added to refs/heads/main by this push:
new 15f838288 fix binlog example to match changelog (#2775)
15f838288 is described below
commit 15f8382883f7b7b9b556b02b808b344e22a62f70
Author: MehulBatra <[email protected]>
AuthorDate: Tue Mar 3 16:37:29 2026 +0530
fix binlog example to match changelog (#2775)
---
website/docs/table-design/virtual-tables.md | 40 +++++++++++++++++------------
1 file changed, 23 insertions(+), 17 deletions(-)
diff --git a/website/docs/table-design/virtual-tables.md
b/website/docs/table-design/virtual-tables.md
index 7ec321516..884fe0325 100644
--- a/website/docs/table-design/virtual-tables.md
+++ b/website/docs/table-design/virtual-tables.md
@@ -169,34 +169,40 @@ The `before` and `after` columns are nested ROW types
containing all columns fro
### Examples
+Consider the same Primary Key Table tracking user orders:
+
```sql title="Flink SQL"
-- Create a primary key table
-CREATE TABLE users (
- user_id INT NOT NULL,
- name STRING,
- email STRING,
- PRIMARY KEY (user_id) NOT ENFORCED
+CREATE TABLE orders (
+ order_id INT NOT NULL,
+ customer_name STRING,
+ amount DECIMAL(10, 2),
+ PRIMARY KEY (order_id) NOT ENFORCED
) WITH ('bucket.num' = '1');
--- Insert, update, then delete a record
-INSERT INTO users VALUES (1, 'Alice', '[email protected]');
-INSERT INTO users VALUES (1, 'Alice Smith', '[email protected]');
-DELETE FROM users WHERE user_id = 1;
+-- Insert a record
+INSERT INTO orders VALUES (1, 'Rhea', 100.00);
+
+-- Update the record
+INSERT INTO orders VALUES (1, 'Rhea', 150.00);
+
+-- Delete the record
+DELETE FROM orders WHERE order_id = 1;
-- Query the binlog
-SELECT * FROM users$binlog;
+SELECT * FROM orders$binlog;
```
Output:
```
-+--------------+-------------+---------------------+----------------------------------+--------------------------------------+
-| _change_type | _log_offset | _commit_timestamp | before
| after |
-+--------------+-------------+---------------------+----------------------------------+--------------------------------------+
-| insert | 0 | 2024-01-15 10:30:00 | NULL
| (1, Alice, [email protected]) |
-| update | 2 | 2024-01-15 10:35:00 | (1, Alice,
[email protected]) | (1, Alice Smith, [email protected]) |
-| delete | 3 | 2024-01-15 10:40:00 | (1, Alice Smith,
[email protected]) | NULL |
-+--------------+-------------+---------------------+----------------------------------+--------------------------------------+
++--------------+-------------+---------------------+----------------------+----------------------+
+| _change_type | _log_offset | _commit_timestamp | before |
after |
++--------------+-------------+---------------------+----------------------+----------------------+
+| insert | 0 | 2024-01-15 10:30:00 | NULL |
(1, Rhea, 100.00) |
+| update | 2 | 2024-01-15 10:35:00 | (1, Rhea, 100.00) |
(1, Rhea, 150.00) |
+| delete | 3 | 2024-01-15 10:40:00 | (1, Rhea, 150.00) |
NULL |
++--------------+-------------+---------------------+----------------------+----------------------+
```
#### Accessing Nested Fields
