flink cdc中对于datastream api开发，需要重写类吧？

在 Flink CDC 中，如果您需要使用 DataStream API 进行开发，则需要重写 Flink CDC 中的 CDCSourceFunction 类。CDCSourceFunction 是 Flink CDC 中的核心组件之一，用于实现增量数据同步的功能。
具体来说，您需要按照以下步骤来使用 DataStream API 进行开发：
继承 CDCSourceFunction 类，并实现其抽象方法。在实现过程中，您需要编写逻辑代码来读取 CDC 数据流，并将其转换为 Flink 的 DataStream 数据流。
在 DataStream 中使用您编写的 CDCSourceFunction。您可以使用 Flink 的 fromFunction 方法将 CDCSourceFunction 包装成一个 DataStream 数据源，例如：
java
Copy
CDCSourceFunction cdcSource = new MyCDCSourceFunction(); // MyCDCSourceFunction 是您实现的 CDCSourceFunction 类
DataStream dataStream = env.addSource(cdcSource);
在上述代码中，MyCDCSourceFunction 是您实现的 CDCSourceFunction 类，env 是 Flink 执行环境对象。
编写逻辑代码对 DataStream 进行处理。您可以使用 Flink 的 DataStream API 编写逻辑代码，对 DataStream 进行转换、过滤、计算等操作，例如：
java
Copy
DataStream resultStream = dataStream
.filter(row -> row.getField(0).toString().startsWith("A"))
.map(row -> {
// 对数据进行转换
return newRow;
});
在上述代码中，resultStream 是经过转换和过滤后的数据流对象。
将处理后的数据流写入目标数据源。在使用 DataStream API 进行开发时，您可以使用 Flink 提供的各种 SinkFunction 将处理后的数据流写入目标数据源，例如：

sql或者datastream api开发都可以操作呀。用人家的类，他是直接Json字段映射，如果要新增字段映射，需要自己改下类。此回答整理至钉群“Flink CDC 社区”。