请问flink cdc中oceanbaseRecord支持标记哪些字段更新了么？

是的，在 Flink CDC 中，当使用 OceanBase CDC 连接器读取数据时，支持标记哪些字段已更新。

具体来说，当使用 Flink Table API 或 SQL API 进行查询时，如果您在 SELECT 子句中指定了需要的列，那么 Flink CDC 将只返回这些列的数据，并且每个返回的行都将包含一个标记，指示哪些列已更新。这个标记可以使用 RowKind 类型来表示，其中 RowKind.INSERT 表示新增行，RowKind.DELETE 表示删除行，RowKind.UPDATE_AFTER 表示更新后的行。

以下是一个示例代码，演示了如何使用 Flink CDC 读取 OceanBase 数据库中的数据，并标记哪些字段已更新：

java
Copy
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;

public class OceanBaseCDCExample {

public static void main(String[] args) throws Exception {
    StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
    StreamTableEnvironment tEnv = StreamTableEnvironment.create(env);

    // 创建 OceanBase CDC 连接器
    tEnv.executeSql("CREATE TABLE my_table (id INT, name STRING, age INT) WITH (" +
            " 'connector' = 'oceanbase-cdc'," +
            " 'hostname' = 'localhost'," +
            " 'port' = '2828'," +
            " 'username' = 'root'," +
            " 'password' = 'root'," +
            " 'database-name' = 'my_database'," +
            " 'table-name' = 'my_table'," +
            " 'debezium.schema-include' = 'id,name,age'" +  // 指定需要的列
            ")");

    // 执行查询操作
    tEnv.sqlQuery("SELECT id, name, age, ROW_KIND FROM my_table").execute().print();

    env.execute("OceanBase CDC Example");
}

}
在上面的示例代码中，我们使用 Flink CDC 的 Table API 和 SQL API，查询了 OceanBas