Hello,
I am trying to read a column of data type set in cassandra. My code is
val setSer = new SetSerializer[String](UTF8Type.instance)
val genres = col.getColumnByName("genres")
val genValue = genres.getValue(setSer).toSet
However this code throws an exception
org.apache.cassandra.serializers.MarshalException: Unexpected extraneous bytes after set value
at org.apache.cassandra.serializers.SetSerializer.deserialize(SetSerializer.java:64)
at org.apache.cassandra.serializers.SetSerializer.deserialize(SetSerializer.java:27)
at org.apache.cassandra.db.marshal.AbstractType.compose(AbstractType.java:142)
at com.netflix.astyanax.serializers.SetSerializer.fromByteBuffer(SetSerializer.java:32)
Regards,
Abhishek.