我正在尝试使用 Avro 架构将 Json 字符串转换为通用 Java 对象。
下面是我的代码。
String json = "{\"foo\": 30.1, \"bar\": 60.2}";
String schemaLines = "{\"type\":\"record\",\"name\":\"FooBar\",\"namespace\":\"com.foo.bar\",\"fields\":[{\"name\":\"foo\",\"type\":[\"null\",\"double\"],\"default\":null},{\"name\":\"bar\",\"type\":[\"null\",\"double\"],\"default\":null}]}";
InputStream input = new ByteArrayInputStream(json.getBytes());
DataInputStream din = new DataInputStream(input);
Schema schema = Schema.parse(schemaLines);
Decoder decoder = DecoderFactory.get().jsonDecoder(schema, din);
DatumReader<Object> reader = new GenericDatumReader<Object>(schema);
Object datum = reader.read(null, decoder);
我得到“org.apache.avro.AvroTypeException:预期的启动联合。得到 VALUE_NUMBER_FLOAT”异常。
如果我在架构中没有联合,则相同的代码可以工作。 有人可以解释一下并给我一个解决方案吗。
最佳答案
对于任何使用 Avro - 1.8.2 的人来说,JsonDecoder
现在不能在 org.apache.avro.io
包外直接实例化。您可以使用 DecoderFactory
作为它,如下面的代码所示:
String schemaStr = "<some json schema>";
String genericRecordStr = "<some json record>";
Schema.Parser schemaParser = new Schema.Parser();
Schema schema = schemaParser.parse(schemaStr);
DecoderFactory decoderFactory = new DecoderFactory();
Decoder decoder = decoderFactory.jsonDecoder(schema, genericRecordStr);
DatumReader<GenericData.Record> reader =
new GenericDatumReader<>(schema);
GenericRecord genericRecord = reader.read(null, decoder);
关于java - Json 字符串到 Java 对象 Avro,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/27559543/