in src/org/apache/pig/data/BinInterSedes.java [1194:1262]
private static byte getGeneralizedDataType(byte type) {
switch (type) {
case BinInterSedes.NULL:
return DataType.NULL;
case BinInterSedes.BOOLEAN_TRUE:
case BinInterSedes.BOOLEAN_FALSE:
return DataType.BOOLEAN;
case BinInterSedes.BYTE:
return DataType.BYTE;
case BinInterSedes.INTEGER_0:
case BinInterSedes.INTEGER_1:
case BinInterSedes.INTEGER_INBYTE:
case BinInterSedes.INTEGER_INSHORT:
case BinInterSedes.INTEGER:
return DataType.INTEGER;
case BinInterSedes.LONG_0:
case BinInterSedes.LONG_1:
case BinInterSedes.LONG_INBYTE:
case BinInterSedes.LONG_INSHORT:
case BinInterSedes.LONG_ININT:
case BinInterSedes.LONG:
return DataType.LONG;
case BinInterSedes.DATETIME:
return DataType.DATETIME;
case BinInterSedes.FLOAT:
return DataType.FLOAT;
case BinInterSedes.DOUBLE:
return DataType.DOUBLE;
case BinInterSedes.BIGINTEGER:
return DataType.BIGINTEGER;
case BinInterSedes.BIGDECIMAL:
return DataType.BIGDECIMAL;
case BinInterSedes.TINYBYTEARRAY:
case BinInterSedes.SMALLBYTEARRAY:
case BinInterSedes.BYTEARRAY:
return DataType.BYTEARRAY;
case BinInterSedes.SMALLCHARARRAY:
case BinInterSedes.CHARARRAY:
return DataType.CHARARRAY;
case BinInterSedes.TUPLE_0:
case BinInterSedes.TUPLE_1:
case BinInterSedes.TUPLE_2:
case BinInterSedes.TUPLE_3:
case BinInterSedes.TUPLE_4:
case BinInterSedes.TUPLE_5:
case BinInterSedes.TUPLE_6:
case BinInterSedes.TUPLE_7:
case BinInterSedes.TUPLE_8:
case BinInterSedes.TUPLE_9:
case BinInterSedes.TUPLE:
case BinInterSedes.TINYTUPLE:
case BinInterSedes.SMALLTUPLE:
return DataType.TUPLE;
case BinInterSedes.BAG:
case BinInterSedes.TINYBAG:
case BinInterSedes.SMALLBAG:
return DataType.BAG;
case BinInterSedes.MAP:
case BinInterSedes.TINYMAP:
case BinInterSedes.SMALLMAP:
return DataType.MAP;
case BinInterSedes.INTERNALMAP:
return DataType.INTERNALMAP;
case BinInterSedes.GENERIC_WRITABLECOMPARABLE:
return DataType.GENERIC_WRITABLECOMPARABLE;
default:
throw new RuntimeException("Unexpected data type " + type + " found in stream.");
}
}