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 2d697329b release fixes for changefeed to include binlog (#2774)
2d697329b is described below
commit 2d697329ba88f1e2c5e2b7d17db57fbd42f823ec
Author: MehulBatra <[email protected]>
AuthorDate: Mon Mar 2 19:48:20 2026 +0530
release fixes for changefeed to include binlog (#2774)
---
website/blog/assets/0.9/cdf_bl.png | Bin 0 -> 30738 bytes
website/blog/assets/0.9/cdf_cl.png | Bin 0 -> 35118 bytes
website/blog/assets/0.9/vt.png | Bin 36274 -> 0 bytes
website/blog/releases/0.9.md | 21 +++++++++++++++++++--
4 files changed, 19 insertions(+), 2 deletions(-)
diff --git a/website/blog/assets/0.9/cdf_bl.png
b/website/blog/assets/0.9/cdf_bl.png
new file mode 100644
index 000000000..d0da4c608
Binary files /dev/null and b/website/blog/assets/0.9/cdf_bl.png differ
diff --git a/website/blog/assets/0.9/cdf_cl.png
b/website/blog/assets/0.9/cdf_cl.png
new file mode 100644
index 000000000..4c0506ece
Binary files /dev/null and b/website/blog/assets/0.9/cdf_cl.png differ
diff --git a/website/blog/assets/0.9/vt.png b/website/blog/assets/0.9/vt.png
deleted file mode 100644
index 0dfb4b93f..000000000
Binary files a/website/blog/assets/0.9/vt.png and /dev/null differ
diff --git a/website/blog/releases/0.9.md b/website/blog/releases/0.9.md
index a6e0c03b5..24575af8c 100644
--- a/website/blog/releases/0.9.md
+++ b/website/blog/releases/0.9.md
@@ -183,7 +183,7 @@ Apache Fluss 0.9 introduces virtual tables `$changelog` and
`$binlog` for change
```sql
SELECT * FROM `orders$changelog`;
```
-
+
Each changelog record includes metadata columns prepended to the original
table columns:
- **`_change_type`**: The type of change operation (`insert`,
`update_before`/`update_after`, `delete` for Primary Key Tables; only `insert`
for Log Tables).
@@ -195,8 +195,22 @@ Users can control where reading begins using startup
modes: `earliest` (full his
#### Binlog Virtual Table
For Primary Key Tables, Fluss also provides a `$binlog` virtual table that
presents change data in a binlog format. Unlike `$changelog`, which shows
individual change records, `$binlog` provides both **before and after images**
in a single record with nested `before` and `after` row structures. This format
is particularly useful for change data capture (CDC) integrations and systems
that need to process both states of a row in a single operation.
+#### Access the binlog of pk table
+```sql
+SELECT * FROM `orders$binlog`;
+```
+
+
+Each binlog virtual table includes three metadata columns followed by nested
before and after row structures:
+
+- **`_change_type`**: The type of change operation (insert, update, delete for
Primary Key Tables).
+- **`_log_offset`**: The position in the log for tracking and replay.
+- **`_commit_timestamp`**: The exact timestamp when the change was committed.
+- **`before ROW<...>`**: The row values before the change (NULL for
inserts).
+- **`after ROW<...>`**: The row values after the change (NULL for deletes).
+
-The `$changelog` virtual table unlocks critical use cases for regulatory and
advanced analytics environments.
+The `$changelog` & `$binlog` virtual table unlocks critical use cases for
regulatory and advanced analytics environments.
#### Compliance, Audit Trails, and AI Reproducibility
For regulatory environments, Fluss provides a complete, atomic audit trail of
all data modifications.
@@ -208,6 +222,9 @@ Storage-level CDC means no extra compute overhead; changes
are already materiali
```sql
SELECT * FROM orders$changelog;
```
+```sql
+SELECT * FROM orders$binlog;
+```
You can find more instructions about how to use virtual tables and the
changelog feature
[here](https://fluss.apache.org/docs/0.9/table-design/virtual-tables/).
