in pig/src/main/java/com/twitter/elephantbird/pig/util/ProtobufToPig.java [163:175]
private Object coerceToPigTypes(FieldDescriptor fieldDescriptor, Object fieldValue) {
if (fieldDescriptor.getType() == FieldDescriptor.Type.ENUM && fieldValue != null) {
EnumValueDescriptor enumValueDescriptor = (EnumValueDescriptor)fieldValue;
return enumValueDescriptor.getName();
} else if (fieldDescriptor.getType() == FieldDescriptor.Type.BOOL && fieldValue != null) {
Boolean boolValue = (Boolean)fieldValue;
return new Integer(boolValue ? 1 : 0);
} else if (fieldDescriptor.getType() == FieldDescriptor.Type.BYTES && fieldValue != null) {
ByteString bsValue = (ByteString)fieldValue;
return new DataByteArray(bsValue.toByteArray());
}
return fieldValue;
}