2011-03-29 7 views
5

Supongamos que tengo el siguiente esquema:Pregunta poblar los registros anidados en Avro utilizando un GenericRecord

{ 
"name" : "Profile", 
"type" : "record", 
"fields" : [ 
    { "name" : "firstName", "type" : "string" }, 
    { "name" : "address" , "type" : { 
    "type" : "record", 
    "name" : "AddressUSRecord", 
    "fields" : [ 
    { "name" : "address1" , "type" : "string" }, 
    { "name" : "address2" , "type" : "string" }, 
    { "name" : "city" , "type" : "string" }, 
    { "name" : "state" , "type" : "string" }, 
    { "name" : "zip" , "type" : "int" }, 
    { "name" : "zip4", "type": "int" } 
    ] 
    } 
} 
] 
} 

estoy usando un GenericRecord para representar cada perfil que se crea. Para agregar un firstName, es fácil hacer lo siguiente:

Schema sch = Schema.parse(schemaFile); 
DataFileWriter<GenericRecord> fw = new DataFileWriter<GenericRecord>(new GenericDatumWriter<GenericRecord>()).create(sch, new File(outFile)); 
GenericRecord r = new GenericData.Record(sch); 
r.put(“firstName”, “John”); 
fw.append(r); 

Pero, ¿cómo podría establecer la ciudad, por ejemplo? ¿Cómo puedo representar la clave como una cadena que el método r.put puede entender?

Gracias

Respuesta

10

Para el esquema anterior:

GenericRecord t = new GenericData.Record(sch.getField("address").schema()); 
t.put("city","beijing"); 
r.put("address",t); 
Cuestiones relacionadas