请教个问题，在debezium自定义转换器中怎么判断当前数据是全量还是增量呢？

可以这样理解，有数据时间戳的都是增量 此答案整理自钉群“Flink CDC 社区”

• 可以通过检查SourceRecord中的操作类型进行判断。操作类型有CREATE、UPDATE和DELETE三种。CREATE表示新增数据的全量，UPDATE表示修改数据的增量，DELETE表示删除数据的增量。因此，如果操作类型为CREATE，则当前数据为全量；如果操作类型为UPDATE或DELETE，则当前数据为增量。可以通过以下代码示例实现：

public class CustomDebeziumConverter implements DebeziumDeserializationSchema<Map<String, String>> {
    @Override
    public void open(DeserializationContext deserializationContext) throws Exception {
        // ...
    }

    @Override
    public Map<String, String> deserialize(SourceRecord sourceRecord) throws Exception {
        String operation = (String) sourceRecord.value().get("op");
        if ("c".equals(operation)) {
            // 新增数据的全量
            // ...
        } else if ("u".equals(operation)) {
            // 修改数据的增量
            // ...
        } else if ("d".equals(operation)) {
            // 删除数据的增量
            // ...
        }
    }

    @Override
    public TypeInformation<Map<String, String>> getProducedType() {
        // ...
    }
}