java - 使用 Java 将 JSON 转换为 Avro

Question

这个问题已经有答案了:

How to Avro Binary encode the JSON String using Apache Avro? (3 个回答)

已关闭 8 年前。

我想将 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;
}