我只想捕获部分字段的变更数据，flink cdc一条数据更新吗，可以查看变更前数据吗？

如果您在 Flink CDC 中将逻辑删除转换为物理删除，可以考虑以下方法：

修改 Debezium JSON 格式的数据：在 CDC 数据中，将操作类型（op）从 "u"（更新）改为 "d"（删除）。这样可以将逻辑删除的操作转换为物理删除。

使用 Flink 的转换函数（Transformation）：在 Flink CDC 程序中，使用转换函数将逻辑删除的操作转换为物理删除。您可以使用 Flink 的 MapFunction、ProcessFunction 或自定义的转换函数来实现此逻辑。在函数中，您可以检查 CDC 数据的操作类型，并根据需要将其转换为物理删除。

以下是一个示例，演示了如何在 Flink CDC 中将逻辑删除转换为物理删除：
```StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

Properties properties = new Properties();
properties.setProperty("bootstrap.servers", "localhost:9092");
properties.setProperty("group.id", "cdc_group");
properties.setProperty("database.server.name", "myOracleServer");

FlinkCDCConsumer consumer = new FlinkCDCConsumer<>("oracle", DebeziumDeserializationSchema.forString(), properties);

DataStream cdcStream = env.addSource(consumer);

DataStream transformedStream = cdcStream.map(new MapFunction() {
@Override
public String map(String value) throws Exception {
// 将逻辑删除操作转换为物理删除
JsonNode jsonNode = objectMapper.readTree(value);
String op = jsonNode.get("op").asText();

if (op.equals("u")) {
  // 将操作类型改为 "d"，表示物理删除
  ((ObjectNode) jsonNode).put("op", "d");
}

return jsonNode.toString();

}
});

// 将转换后的数据写入目标库
transformedStream.addSink(...); // 指定合适的 Sink，将数据写入目标库

env.execute("CDC Transformation Example");

```
在上述示例中，我们使用 MapFunction 来进行转换。在 map() 方法中，我们解析 CDC 数据的 JSON，并检查操作类型。如果操作类型为 "u"，则将其改为 "d"，表示物理删除。然后，我们将转换后的数据写入目标库的适当 Sink。

请根据实际需求和环境进行适当调整，并根据目标库的要求进行数据写入操作。

除了以上方法，您还可以考虑使用 Flink 的 ProcessFunction 或 RichMapFunction 来实现更复杂的转换逻辑，以满足特定的需求。

请注意，在执行任何删除操作之前，请确保您已经备份了相关的数据，并与相关团队或 DBA 进行充分沟通和确认。