Details
Description
CassandraStorage doesn't decode name in widerow mode. This causes functions such as FILTER to fail with a ClassCastException, since the key is a bytearray instead of a chararray.
test.pig
DEFINE CassandraStorage org.apache.cassandra.hadoop.pig.CassandraStorage; A = LOAD 'cassandra://Metrics/EventEntries?widerows=true' USING CassandraStorage(); -- describe A --> A: {key: chararray,columns: {(name: (),value: chararray)}} B = FILTER A BY key matches '^user.hit'; -- Throws CCE: org.apache.pig.data.DataByteArray cannot be cast to java.lang.String