请问flink cdc中有没有demo，说下怎么改写sink映射类的？

在 Flink CDC 中，可以通过修改 DeserializationSchema 和 SerializationSchema 实现数据的格式转换和映射。具体的做法是，在 DeserializationSchema 中定义输入数据的格式，并将其转换为 Flink 中的数据类型；在 SerializationSchema 中定义输出数据的格式，并将 Flink 中的数据类型转换为输出格式。
下面是一个简单的示例，展示如何编写一个 DeserializationSchema 和 SerializationSchema，并将其用于 Flink CDC 的数据处理流程中。
编写 DeserializationSchema
java
Copy
public class MyRecordDeserializationSchema implements DeserializationSchema {

private final TableSchema schema;

public MyRecordDeserializationSchema(TableSchema schema) {
    this.schema = schema;
}

@Override
public MyRecord deserialize(byte[] bytes) throws IOException {
    // 将字节数组转换为字符串
    String str = new String(bytes, StandardCharsets.UTF_8);

    // 将字符串解析为 JSON 对象
    JSONObject json = JSON.parseObject(str);

    // 从 JSON 对象中解析出 id、name、age 字段的值
    int id = json.getIntValue("id");
    String name = json.getString("name");
    int age = json.getIntValue("age");

    // 创建 MyRecord 对象，并返回
    return new MyRecord(id, name, age);
}

@Override
public boolean isEndOfStream(MyRecord myRecord) {
    return false;
}

@Override
public TypeInformation<MyRecord> getProducedType() {
    return Types.POJO(MyRecord.class);
}

}
在这个例子中，MyRecordDeserializationSchema 将输入数据解析为 MyRecord 类型