Вопрос о заполнении вложенных записей в Avro с помощью 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" }
   ]
  }
 }
]
}

Я использую GenericRecord для представления каждого создаваемого профиля. Чтобы добавить firstName, легко сделать следующее:

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

Но как мне, например, установить город? Как представить ключ в виде строки, понятной для метода r.put?

Спасибо

8
задан pawstrong 5 September 2011 в 04:21
поделиться

0 ответов

Другие вопросы по тегам:

Похожие вопросы: