[FLINK-30341] Introduce audit_log system table

• Type: New Feature
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: table-store-0.3.0
• Labels: pull-request-available
• Assignee: Jingsong Lee
• Reporter: Jingsong Lee
• Created: 08/Dec/22 12:11
• Updated: 12/Dec/22 09:55
• Resolved: 12/Dec/22 08:19

Description

In some scenarios, users need to get the changelog to do some auditing work, such as determining the number of updates and inserts.

We can provide audit_log system table, users can get the rowkind information column.

INSERT INTO T VALUES ('1', '2', '3');
INSERT INTO T VALUES ('1', '4', '5');

SELECT * FROM T$audit_log;

users can get:
- "+I", "1", "2", "3"
- "-U", "1", "2", "3";
- "+U", "1", "4", "5"

Issue Links

• links to: GitHub Pull Request #428
• links to: GitHub Pull Request #431