[jira] [Created] (FLINK-30341) Introduce audit_log system table

["Jingsong Lee (Jira)" <ji...@apache.org>]

Jingsong Lee created FLINK-30341:
------------------------------------

             Summary: Introduce audit_log system table
                 Key: FLINK-30341
                 URL: https://issues.apache.org/jira/browse/FLINK-30341
             Project: Flink
          Issue Type: New Feature
            Reporter: Jingsong Lee
            Assignee: Jingsong Lee
             Fix For: table-store-0.3.0


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.


{code:java}
INSERT INTO %s VALUES ('1', '2', '3');
INSERT INTO %s VALUES ('1', '4', '5');

SELECT * FROM T$audit_log;

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




--
This message was sent by Atlassian Jira
(v8.20.10#820010)