使用 Java 将 JSON 转换为 Avro [重复]

Question

我想将 JSON 数据转换为 Avro 文件。那么如何通过 Java API/代码来实现呢？

我的示例 JSON 文件是：

[
  {
    "ProductID": "101.0",
    "Id": "1.0",
    "OrderID": "1111.0",
    "Name": "John"
  },
  {
    "ProductID": "102.0",
    "Id": "2.0",
    "OrderID": "2222.0",
    "Name": "Taylor"
  }
]

那么第一件事，我如何从 JSON 文件创建 Avro 模式文件？

其次，创建Avro schema后，如何转换成Avro文件？

Answer 1

检查以下代码是否对您有用。

public <T> T jsonDecodeToAvro(String inputString, Class<T> className,
Schema schema) {

     T returnObject = null;

     try {

         JsonDecoder jsonDecoder = DecoderFactory.get().jsonDecoder(schema,
inputString);

         SpecificDatumReader<T> reader = new
SpecificDatumReader<T>(className);

         returnObject = reader.read(null, jsonDecoder);

     } catch (IOException e) {

         e.printStackTrace();

     }



     return returnObject;
}