在没有 Class(-Object) 的情况下创建 Avro 模式

Question

目前我正在将 class 序列化为 avsc 模式。这很好用：

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

但是，我需要创建一个 AVSC ，而不需要任何给定的动态 class。这可能吗？

Answer 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();

在没有 Class(-Object) 的情况下创建 Avro 模式

Creating Avro Schema without Class(-Object)

schema

hadoop

avro

kite

avsc