ProtobufRowConverter.java 文件源码

@Override
public Row decode(DynamicMessage msg) {
    boolean first = true;
    Row row = null;
    for (FieldDescriptor field : msg.getAllFields().keySet()) {
        ProtobufRowConverter tableConverter = 
            tableConvertersByField.get(field);
        if (tableConverter != null) {
            assert first;
            first = false;
            row = tableConverter.decode((DynamicMessage)msg.getField(field));
        }
    }
    assert !first;
    return row;
}