主页 / 问题 / 932731
Accepted
Леонид Дубравский
Asked:2020-01-16 17:35:24 +0000 UTC2020-01-16 17:35:24 +0000 UTC

创建 Avro 架构时如何为字段添加多种类型？

  • 772

有一种创建 Avro 模式的方法：

public void schemaCreator(String recordName, EntityModel entityModel){
        SchemaBuilder.FieldAssembler<Schema> fields;
        SchemaBuilder.RecordBuilder<Schema> record = SchemaBuilder.record(recordName);
        fields = record.namespace("Test").fields();
        for (AttributeModel attributeModel : entityModel.getAttributeModels()) {


            fields = fields.name(attributeModel.getName()).type().nullable().stringType()
                    .noDefault();

        }
    }

结果，我们有一个图表：

{
 "type":"record",
 "name":"InfoData",
 "namespace":"Test",
 "fields":[
   {
    "name":"Setting",
    "type":["string","null"]
   },
   {
    "name":"Value",
    "type":["string","null"]}]
   }

如何为一个字段添加多种类型？例如："type":["string","long","boolean","null"]}]

java

1 个回答

  1. Best Answer

    这是一个解决方案，因此您可以在循环中形成类型列表： 

    public void schemaCreator(String recordName, EntityModel entityModel){
        SchemaBuilder.FieldAssembler<Schema> fields;
        SchemaBuilder.RecordBuilder<Schema> record = SchemaBuilder.record(recordName);
        fields = record.namespace("Test").fields();
        final Schema intType = Schema.create(Schema.Type.INT);
        final Schema booleanType = Schema.create(Schema.Type.BOOLEAN);
        final Schema nullType = Schema.create(Schema.Type.NULL);

        for (AttributeModel attributeModel : entityModel.getAttributeModels()) {
            Schema unionSchema = Schema.createUnion(Arrays.asList(nullType, intType, booleanType));
            fields.name(attributeModel.getName()).type(unionSchema).noDefault();
        }
    }
    • 0

相关问题