Using DSE 1.x
I have a simple CF with UTF8 key, column, & value.
I can use the column or value in a join or group by, but if I try to use the key, I get the following error:
Type mismatch in key from map: expected org.apache.pig.impl.io.NullableText, recieved org.apache.pig.impl.io.NullableBytesWritable
Simplest example:
p1 = LOAD 'cassandra://keyspace/CF' USING CassandraStorage() AS (key:chararray, columns: bag{T: tuple(property:chararray, value:chararray)});
p2 = group p1 by columns::property;
dump p2;
Works just fine, but changing the group by to:
p2 = group p1 by key;
dump p2;
will fail with the type mismatch error.
However, if I do a load, using the same schema, from a text file with lines of the form:
key {(c1,v1),(c2,v2),(c3,v3)}
I can group (or join) by the key successfully.
Any suggestions for work around?
Thanks,
John
