如何反序列化DynamicComposite列值？

Question

我想实现一个数据模型，其中行键是字符串，列名是长和列值是DynamicComposites。使用赫克托，存储过程的一个例子是这样的：

// create the value 
DynamicComposite colVal = new DynamicComposite(); 
colVal.add(0, "someString"); 
colVal.setComparatorByPosition(0, "org.apache.cassandra.db.marshal.UTF8Type"); 
colVal.setSerializerByPosition(0, StringSerializer.get()); 

// create the column 
HColumnImpl<Long, DynamicComposite> newCol = new 
    HColumnImpl<Long, DynamicComposite>(longSerializer, 
     dynamicCompositeSerializer); 

newCol.setName(longValue); 
newCol.setValue(colVal); 
newCol.setClock(keySpace.createClock()); 

// insert the new column 
Mutator<String> mutator = HFactory.createMutator(keySpace,stringSerializer); 
mutator.addInsertion("rowKey","columnFamilyName",newCol); 
mutator.execute(); 

现在，当我尝试检索数据：

// create the query 
SliceQuery<String,Long,DynamicComposite> sq = 
    HFactory.createSliceQuery(keySpace, stringSerializer, longSerializer, 
     dynamicCompositeSerializer); 

// set the query 
sq.setColumnFamily("columnFamilyName"); 
sq.setKey("rowKey"); 
sq.setColumnNames(longValue); 

// execute the query 
QueryResult<ColumnSlice<Long, DynamicComposite>> qr = sq.execute(); 

// get the data 
qr.get().getColumnByName(longValue).getValue(); 

或当我只是试图让普通轮空：

// get the data  
dynamicSerializer.fromByteBuffer(qr.get(). 
    getColumnByName(longValue).getValueBytes()); 

我碰到一个例外：

Exception in thread "main" java.lang.NullPointerException 
    at com.google.common.base.Preconditions.checkNotNull(Preconditions.java:191) 
    at com.google.common.collect.ImmutableClassToInstanceMap.getInstance(ImmutableClassToInstanceMap.java:147) 
    at me.prettyprint.hector.api.beans.AbstractComposite.serializerForComparator(AbstractComposite.java:321) 
    at me.prettyprint.hector.api.beans.AbstractComposite.getSerializer(AbstractComposite.java:344) 
    at me.prettyprint.hector.api.beans.AbstractComposite.deserialize(AbstractComposite.java:713) 
    at me.prettyprint.hector.api.beans.DynamicComposite.fromByteBuffer(DynamicComposite.java:25) 
    at me.prettyprint.cassandra.serializers.DynamicCompositeSerializer.fromByteBuffer(DynamicCompositeSerializer.java:35) 

据我所了解的所有教程所了解，应该可以使用DynamicComposite作为列值。所以我想问：我做错了什么？从例外情况看，我只是忘了在某个地方设置一些东西。

Answer 1

拉多，

它可能是由于一起选择使用赫克托版本的番石榴库的兼容性问题。

参见：https://github.com/hector-client/hector/pull/591

我对赫克托 - 核心1.1-1.jar，与番石榴14.0.jar组合，我得到了同样的错误，你。当我将它与Guava-12.0.1.jar一起使用时，它对我来说工作正常。