ProtobufRowConverter.java 文件源码

@Override
public Row decode(DynamicMessage msg) {
    Object[] objects = new Object[fields.length];
    for (FieldDescriptor field : msg.getAllFields().keySet()) {
        Integer columnIndex = columnIndexesByField.get(field);
        if (columnIndex != null) {
            objects[columnIndex] = conversions[columnIndex].getValue(msg, field);
        }
        else {
            Integer nullIndex = nullableIndexesByField.get(field);
            if (nullIndex != null) {
                // TODO: It's already null, because we aren't
                // handling defaults yet.
                objects[nullIndex] = null;
            }
        }
    }
    ValuesHolderRow row = new ValuesHolderRow (rowType, objects);
    return row;
}