问题标签 [hector]

您好，我正在尝试使用 hector 从 cassandra 获取数据。有两种方法可以做到这一点。

一个是这样的 cqlQuery：

如果没有查询，它应该是这样的，但我无法让它工作：

我在哪里犯错？

我有一个超级列族：

这是一个代码：

我想要做的是从 nameKey 列族中获取所有列名，但它只返回前 7 个名称{name1, name2,..., name7}（第 2 行）但计数返回8945（第 1 行）。断言在第 3 行失败......

为了提高我对 Hector 和 cassandra 的技能，我正在尝试不同的方法从 cassandra 中查询数据。

目前我正在尝试制作一个简单的消息系统。我想按时间顺序获取发布的消息，最后发布的消息首先。

在纯 sql 中，可以使用“order by”。我知道如果您使用 OrderPreservingPartitioner 是可能的，但是这个分区器已被弃用并且效率低于 RandomPartioner。我想在具有时间戳 als 值的辅助列上创建一个索引，但我不知道如何获取数据。我确定我必须使用至少两个查询。

我的专栏家庭看起来像这样：

我不确定是否应该对索引列使用 DataType 或 long，但我认为这对于这个问题并不重要。

那么如何才能对数据进行排序呢？如果可能的话，我想知道它是如何完成白色 CQL 语法和 whitout 的。

提前致谢。

我存储CompositeType的数据如下所示：

复合有四个部分：[时间戳：类型：价格：属性名称]

是否可以使用 查询 1、2 或所有组件SliceQuery？

• 例如，我想从时间戳 T1 --> T2 查询（工作正常）
• 还需要说时间戳 T1 --> T2 and Type = "C" and only "C"
• 时间戳 T1 --> T2，类型 = "C" AND price = "365.0"

是否可以以这种方式查询复合材料的一部分？到目前为止，在我的测试中，我还没有能够将复合材料进行比较，就好像它只是长字节数组一样——而不是单个组件。

使用 MultigetSliceQuery 时，结果将包含每个键的一行，即使该键不存在。唯一的测试方法可能是检查每一行是否存在任何列。

但是，如果我创建一个包含 1 列或更多列的行，然后删除所有列，则 MultigetSliceQuery 的结果将是相同的（就好像该行从未创建过一样）。

当使用 CLI 进行测试时，“ list CF ”将显示空行键，但“ get CF[key] ”将返回“ Returned 0 results ” 。

没有任何列的行是否有效？

是否应该有办法检查空与存在的结果？

我们一直在使用 Cassandra 0.7，由于 cassandra 1.0.0 的稳定版本已经发布，我们计划升级到它。它的风险很低，因为我们还没有生产。我们使用的是 hector 0.7-29，它有 testutils 包和一个 EmbeddedServerHelper 类，我们用来在我们所有的单元测试中启动一个嵌入式服务器。

然而，升级版的 hector 1.0-1（用于 cassandra 1.0.x）已经从其核心发行版中删除了这个包（me.prettyprint.cassandra.testutils）。

我想知道使用新的 hector 1.0-1 api 客户端进行单元测试的计划。有没有办法再启动 cassandra 嵌入式服务器？

谢谢你的帮助。

我正在使用 Hector 与来自 java 应用程序的 cassandra 数据库进行交互。（赫克托 1.0-1）

在此示例中，它显示了如何插入（或更新）字段。

但是，关于手术结果的信息并不多。我们如何验证操作是否成功？返回值是一个 ResultStatus 实现，可以调用的 3 个方法是：

我可以假设如果没有异常调用 execute() 方法，那么操作成功了吗？

我是 NoSQL 和 Cassandra 的新手。我正在尝试设置以实现仅内存缓存的解决方案。我正在通过从 100000 行文件中逐行读取并使用 Hector 插入到 Cassandra 来进行处理。我注意到每秒大约 6000 次插入的吞吐量非常低。整个写操作大约需要 20.5 秒，这对我们的应用程序来说是无法接受的。我们需要每秒 100000 次插入。我正在使用 4GB RAM 的 Windows 7 计算机上进行测试。

我正在做一个仅插入测试。

请让我知道我哪里出错了。请建议我如何提高每秒插入次数。

我尝试了几种设置行缓存和键缓存的方法：

1. 通过 Cassandra CLI

2. 通过NodeCmd：java org.apache.cassandra.tools.NodeCmd -p 7199 setcachecapacity Keyspace1 user 150000 150000

当我尝试使用 pelops api 将数据插入 cassandra 时出现以下错误

我正在使用以下罐子

1. scale7-core-1.3.0.jar
2. scale7-pelops-0.912-0.7.0-rc4-1.jar
3. cassandra-1.0.5的lib目录下的所有jar

调用以下函数会导致异常

错误堆栈如下：

我正在寻找一个代码示例来检索列族的所有行和所有列。就像是：

我看到这可以使用 RangeSlicesQuery 来完成，但您仍然必须提供一定的范围。而且我认为您也必须指定列名。有没有一种干净安全的方法来做到这一点？

使用 Hector 1.0 和 Cassandra 1.0。