Description
CassandraStorage uses the validator classes to determine how to marshal column values, if the type is IntegerType a BigInteger is returned and Pig throws an exception on writing the value to intermediate storage. The exception is thrown because BigInteger is not one of the data types that Pig can handle.