java - Avro 迭代 GenericRecord

Question

我有一个 GenericRecord，并且想要迭代整个键/值集合。记录是一个java数据结构，相当于一个普通的json字符串。例如:

    {"key1":"val1","key2":val2",...} but is quite long. 

问题是，我不知道里面有多少个 key,vals。

我已经尝试过:

    AvroKeyValue<String,String> kv = new AvroKeyValue<>(record);
    Iterator<String,String> iterator = new AvroKeyValue.Iterator<String,String>(kv);

但这不起作用。

关于它的 apache 文档在这里: http://avro.apache.org/docs/1.7.0/api/java/org/apache/avro/hadoop/io/AvroKeyValue.Iterator.html

Answer 1

使用GenericRecord的架构列出可用字段

for (Field field : record.getSchema().getFields()) {
    String fieldKey = field.name();
    System.out.println(fieldKey + " : " + record.get(fieldKey));
}