0
請參見下面的示例代碼:Avro公司:ReflectDatumWriter不輸出模式信息
User datum = new User("a123456", "[email protected]");
Schema schema = ReflectData.get().getSchema(datum.getClass());
DatumWriter<Object> writer = new ReflectDatumWriter<>(schema);
ByteArrayOutputStream output = new ByteArrayOutputStream();
Encoder encoder = EncoderFactory.get().binaryEncoder(output, null);
writer.write(datum, encoder);
encoder.flush();
byte[] bytes = output.toByteArray();
System.out.println(new String(bytes));
主要生產:
[email protected]
我認爲,所有的Avro作家將出版模式信息以及與數據,但這不是。
我可以成功,如果我在組合使用GenericDatumWriter
用DataFileWriter
獲取模式打印,但我希望用ReflectDatumWriter
,因爲我不希望建立一個GenericRecord
自己(我希望庫做到這一點)
我該如何獲得架構序列化呢?