gpt4 book ai didi

cassandra - 使用 Hector 通过 cassandra 的键检索一行

转载 作者:行者123 更新时间:2023-12-02 02:22:44 25 4
gpt4 key购买 nike

我正在插入一个 CF,一切正常,我也可以通过简单的方式从 cassandra-cli 读取整行

get columnFamily[lexicaluuid(de80a290-dd71-11e0-8f9d-f81edfd6bd91)];

每一列的键是一个timeUUID:

key = TimeUUIDUtils.getUniqueTimeUUIDinMillis();

CF的部分描述:

ColumnFamily: columnFamily
Key Validation Class: org.apache.cassandra.db.marshal.TimeUUIDType
Default column value validator: org.apache.cassandra.db.marshal.BytesType
Columns sorted by: org.apache.cassandra.db.marshal.UTF8Type

我们还更改了 key 验证类以使用 BytesType UTF8Type 和 TimeUUIDType 进行测试。

作为来自 Java 的 cassandra 客户端,我使用的是 Hector。

当我在知道其 ID 的情况下尝试获取一行时,我无法检索到任何内容。

例子:

String rowKey = "de80a290-dd71-11e0-8f9d-f81edfd6bd91";
SliceQuery<UUID, String, String> result =HFactory.createSliceQuery(CassandraManager.getKeyspace(), UUIDSerializer.get(), StringSerializer.get(), StringSerializer.get());
result.setColumnFamily("columnFamily");
result.setKey(UUIDSerializer.get().fromByteBuffer(StringSerializer.get().toByteBuffer(rowKey)));

result.setColumnNames(COLUMNS); //COLUMNS ins a predefined list of colums
QueryResult <ColumnSlice<String, String>> columnSlice = result.execute();
System.out.println(columnSlice.get().getColumnByName(name).getValue());

结果是以下异常:

me.prettyprint.hector.api.exceptions.HInvalidRequestException: InvalidRequestException(why:Invalid version for TimeUUID type.)
at me.prettyprint.cassandra.service.ExceptionsTranslatorImpl.translate(ExceptionsTranslatorImpl.java:50)
at me.prettyprint.cassandra.service.KeyspaceServiceImpl$7.execute(KeyspaceServiceImpl.java:285)
at me.prettyprint.cassandra.service.KeyspaceServiceImpl$7.execute(KeyspaceServiceImpl.java:268)
at me.prettyprint.cassandra.service.Operation.executeAndSetResult(Operation.java:101)
at me.prettyprint.cassandra.connection.HConnectionManager.operateWithFailover(HConnectionManager.java:232)
at me.prettyprint.cassandra.service.KeyspaceServiceImpl.operateWithFailover(KeyspaceServiceImpl.java:131)
at me.prettyprint.cassandra.service.KeyspaceServiceImpl.getSlice(KeyspaceServiceImpl.java:289)
at me.prettyprint.cassandra.model.thrift.ThriftSliceQuery$1.doInKeyspace(ThriftSliceQuery.java:53)
at me.prettyprint.cassandra.model.thrift.ThriftSliceQuery$1.doInKeyspace(ThriftSliceQuery.java:49)...

我还尝试在 sliceQuery 定义中使用 StringSerializer 作为 keySerializer,但我没有得到异常,但没有结果。

我想我的问题基本上是“如何通过键检索行查询?” :)

这似乎是一个愚蠢的问题,但让我发疯了好几天。

最佳答案

这一行是错误的,

result.setKey(UUIDSerializer.get().fromByteBuffer(StringSerializer.get().toByteBuffer(rowKey)));

相反,你想做类似的事情,

result.setKey(java.util.UUID.fromString(rowKey));

StringSerializer.get().toByteBuffer(rowKey)) 为您提供一个字节缓冲区,其中包含 36 个 utf-8 字节的 rowKey。这与 uuid 的序列化形式不同,它是 16 个字节(一个长 msb,然后是一个长 lsb)。

在这种情况下可能根本不需要使用字符串。只需在您的代码中各处使用 TimeUUIDSerializer 和 com.eaio.uuid.UUID。

关于cassandra - 使用 Hector 通过 cassandra 的键检索一行,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/7395354/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com