0

目前我正在将一个类序列化为 avsc 模式。这很好用:

DatasetDescriptor desc = new DatasetDescriptor.Builder().schema(ClassName.class).build();

但是,我需要动态创建一个没有任何给定类的 AVSC 。这可能吗?

4

1 回答 1

1

有可能的。您可以即时创建架构或读取 avro 架构。以下代码使用硬编码模式,但基本相同

Schema schema = new Schema.Parser().parse("{\"namespace\": \"example.avro\",\n" +
        " \"type\": \"record\",\n" +
        " \"name\": \"User\",\n" +
        " \"fields\": [\n" +
        "     {\"name\": \"name\", \"type\": \"string\"},\n" +
        "     {\"name\": \"favorite_number\",  \"type\": [\"int\", \"null\"]},\n" +
        "     {\"name\": \"favorite_color\", \"type\": [\"string\", \"null\"]}\n" +
        " ]\n" +
        "}");
DatasetDescriptor desc = new DatasetDescriptor.Builder().schema(schema).build();
于 2017-11-09T15:20:22.663 回答