有没有一种方法可以在Java中区分两个Avro GenericRecords，从而只获取更改的字段和值？

Question

我想写Java代码来区分保存在内存中的两个通用记录，它们都有相同的模式。我找不到任何库或任何ApacheAvroJavadoc来说明如何做到这一点。

我的愿望是尽可能高效，并将通用记录转换为JSON，然后区分它们，然后将JSON转换回通用记录将是不可取的，除非这是唯一的选择。

protected GenericRecord generateDeltaFieldsOnly(GenericRecord storedRecord, GenericRecord newRecord) 
{

    ObjectMapper objectMapper = new ObjectMapper();
    JsonNode storedRecordJson = objectMapper.readTree(storedRecord.toString());
    JsonNode newRecordJson = objectMapper.readTree(newRecord.toString());

}

Answer 1

抱歉现在才看到这个...

只需将这两个字段都保留为genericords，并从模式中遍历字段即可更改所需的字段。我可以这样做，但是使用来自两个不同模式的genericords，并用关键字标记模式描述，这些关键字通知基本上愚蠢的转换器进行映射。

@Override
public GenericRecord transform(GenericRecord source, GenericRecord reference) {
    GenericRecordBuilder builder = new GenericRecordBuilder(targetSchema);
    buildGenericRecord(builder, source);
    buildGenericRecord(builder, reference);
    return builder.build();
}

private void buildGenericRecord(GenericRecordBuilder builder, GenericRecord genericRecord) {
    String fullName = genericRecord.getSchema().getFullName();
    String targetField;
    for (Entry<String, String> entry : fromFieldToField.entrySet()) {
        if (entry.getKey().startsWith(fullName)) {
            targetField = entry.getKey().substring(entry.getKey().lastIndexOf('.') + 1);
            builder.set(entry.getValue(), genericRecord.get(targetField));
        }

    }

}

对于你来说，如果你使用相同的模式，这会容易得多。

for (Field field : storedRecord.getSchema().getFields()) {

        //do your mapping field to field

}