in pig/src/main/java/com/twitter/elephantbird/pig/util/ThriftToPig.java [325:347]
private static byte getPigDataType(Field field) {
switch (field.getType()) {
case TType.BOOL:
case TType.BYTE:
case TType.I16:
case TType.I32:
return DataType.INTEGER;
case TType.ENUM:
if (useEnumId) {
return DataType.INTEGER;
} else {
return DataType.CHARARRAY;
}
case TType.I64:
return DataType.LONG;
case TType.DOUBLE:
return DataType.DOUBLE;
case TType.STRING:
return field.isBuffer() ? DataType.BYTEARRAY : DataType.CHARARRAY;
default:
throw new IllegalArgumentException("Unexpected type where a simple type is expected : " + field.getType());
}
}