用AVRO编码可选字符串

Question

我使用的是Avro版本1.10.2

我有以下模式，optionalfield作为可选JSON字符串：

{
  "namespace": "foo.bar",
  "name": "FooBar",
  "type": "record",
  "fields": [
    {
      "name": "optionalField",
      "type": [
        "null",
        "string"
      ]
    }
  ]
}

我使用Avro Maven插件来执行代码生成。

但是，当我使用以下代码对此对象的实例进行编码时：

FooBar fooBar = FooBar.newBuilder()
                .setOptionalField("value")
                .build();

Schema schema = fooBar.getSchema();
ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
Encoder jsonEncoder = EncoderFactory.get().jsonEncoder(schema, byteArrayOutputStream);
SpecificDatumWriter<Object> writer = new SpecificDatumWriter<>(schema);
writer.write(fooBar, jsonEncoder);
jsonEncoder.flush();

System.out.println(byteArrayOutputStream.toString());

输出为：

{"optionalField":{"string":"value"}}

而不是我所期望的：

{"optionalField":"value"}

据我所知，Avro规范中似乎没有任何内容暗示只有记录可以是可选的。此外，根据工会：

如上所述，联合是使用JSON数组表示的。例如，[“null”,“string”]声明一个模式，该模式可以是null或字符串。

我的理解是否正确，Avro真的允许可选字符串字段？这是窃听器吗？我错过了什么？

Answer 1

我的理解是否正确，Avro真的允许可选字符串字段？

是的，Avro支持null和string的联合

我错过了什么？

Avro JSON编码器的工作方式与您预期的不同。正如https://avro.apache.org/docs/current/spec.html#json_encoding中提到的，联合是以类型信息作为字典而不是仅仅以值来编码的。Avro ticket tracker中有一个悬而未决的问题，它要求您查找的格式，但尚未解决:https://issues.apache.org/jira/browse/avro-1582