给定arvo模式和Json数组，如何将它们转换为Avro GenericRecord列表？

Arvo 是一种数据序列化系统，它提供了丰富的数据结构类型，快速可压缩的二进制数据格式，用于存储和交换数据。GenericRecord 是 Avro 中的一个接口，用于表示 Avro 数据模式中的记录。以下是将 JSON 数组转换为 Avro GenericRecord 列表的基本步骤：

基础概念

Avro 模式（Schema）：定义了数据的结构，包括字段名称、类型和顺序。
GenericRecord：Avro 中的一个接口，用于表示模式定义的记录。
DatumReader 和 DatumWriter：用于读取和写入 Avro 数据的接口。
JsonDecoder 和 JsonEncoder：用于处理 JSON 格式的数据。

转换步骤

定义 Avro 模式：首先需要有一个 Avro 模式文件（.avsc），它描述了数据的结构。
解析 JSON 数组：将 JSON 数组转换为 Java 中的数据结构，如 List 或数组。
创建 DatumReader 和 JsonDecoder：使用 Avro 的 DatumReader 和 JsonDecoder 来读取 JSON 数据。
创建 DatumWriter 和 BinaryEncoder：使用 DatumWriter 和 BinaryEncoder 将 GenericRecord 写入二进制格式。
转换数据：遍历 JSON 数据，将其转换为 GenericRecord 对象，并添加到列表中。

示例代码

假设我们有一个简单的 Avro 模式文件 user.avsc：

{
  "type": "record",
  "name": "User",
  "fields": [
    {"name": "name", "type": "string"},
    {"name": "age", "type": "int"}
  ]
}

以下是将 JSON 数组转换为 Avro GenericRecord 列表的 Java 代码示例：

import org.apache.avro.Schema;
import org.apache.avro.generic.GenericData;
import org.apache.avro.generic.GenericRecord;
import org.apache.avro.io.*;
import java.io.ByteArrayOutputStream;
import java.io.StringReader;
import java.util.ArrayList;
import java.util.List;

public class AvroJsonConverter {
    public static void main(String[] args) throws Exception {
        // Avro 模式字符串
        String schemaString = "{\"type\":\"record\",\"name\":\"User\",\"fields\":[{\"name\":\"name\",\"type\":\"string\"},{\"name\":\"age\",\"type\":\"int\"}]}";
        Schema schema = new Schema.Parser().parse(new StringReader(schemaString));

        // JSON 数组字符串
        String jsonArrayString = "[{\"name\":\"Alice\",\"age\":30},{\"name\":\"Bob\",\"age\":25}]";

        // 创建 DatumReader 和 JsonDecoder
        DatumReader<GenericRecord> datumReader = new GenericDatumReader<>(schema);
        JsonDecoder jsonDecoder = DecoderFactory.get().jsonDecoder(schema, jsonArrayString);

        // 创建 DatumWriter 和 BinaryEncoder
        DatumWriter<GenericRecord> datumWriter = new GenericDatumReader<>(schema);
        ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
        BinaryEncoder binaryEncoder = EncoderFactory.get().binaryEncoder(outputStream, null);

        // 解析 JSON 数组并转换为 GenericRecord 列表
        List<GenericRecord> records = new ArrayList<>();
        while (jsonDecoder.hasNext()) {
            GenericRecord record = datumReader.read(null, jsonDecoder);
            records.add(record);
        }

        // 输出转换后的 GenericRecord 列表
        for (GenericRecord record : records) {
            System.out.println(record);
        }
    }
}