将数据插入 Cassandra 时出现 LongType 和 FloatType 的问题

Question

我使用 Hector 将数据插入到 cassandra 数据库中，使用以下代码：

mutator.addInsertion(key, columnfamily, HFactory
                .createStringColumn(dataproperties.getObjectIDcolumnName(),
                        line.objectid));

mutator.addInsertion(key,columnfamily,
                    HFactory.createColumn(dataproperties.getNumtvaluecolomnname(), java.lang.Float.valueOf(value), StringSerializer.get(), FloatSerializer.get()));

numvalue 列定义为 FloatTYPE

我的代码执行没有错误，但是当我检查数据浮点值错误时（我有这种值：C\xb3\x00\x00 当我期望 41.0 时） 字符串数据正确插入 如何正确插入来自 Hector 的数字数据以便进行正确查询

谢谢。

Answer 1

我认为你的列族定义有问题，试试这个

create column family columnfamily
with column_type = 'Standard' 
and comparator = 'UTF8Type' 
and default_validation_class = 'FloatType' 
and key_validation_class = 'UTF8Type' ;

Insertion(key,columnfamily,
                HFactory.createColumn(dataproperties.getNumtvaluecolomnname(),
java.lang.Float.valueOf(value), StringSerializer.get(),
me.prettyprint.cassandra.serializers.FloatSerializer.FloatSerializer.get()));

获取数据

SliceQuery<String,String,byte[]> sliceQuery = HFactory.createSliceQuery(keyspace, se, se,BytesArraySerializer.get());
sliceQuery.setColumnFamily("columnfamily");
        sliceQuery.setKey(key);
        sliceQuery.setRange(null,null,true,10);
        List<HColumn<String,byte[]>> hcolumns = sliceQuery.execute().get()
                .getColumns();
        for (HColumn<String, byte[]> hcolumn : hcolumns){
            System.out.println("Name "+hcolumn.getName());
        System.out.println("Value"+
        FloatSerializer.get().fromBytes(hcolumn.getValue()));
        }

FloatSerializer.get().fromBytes(hcolumn.getValue()) 将值字节数组转换为浮点数