问题标签 [astyanax]

我需要了解对 MutationBatch.execute() 的调用是否/如何防止运行代码的服务器出现故障。

看看下面的代码（从 Astyanax 示例中复制）。我打算使用此代码修改 2 个不同列族中的 2 行。我需要确保（100%）如果执行此代码的服务器在执行期间的任何时候崩溃/失败： - Cassandra 数据存储中没有任何更改 -所有更改（2 行）都应用于 Cassandra 数据存储

我特别关心“OperationResult result = m.execute();”这一行。我假设这会转化为：将所有修改写入 Cassandra 中的提交日志，然后自动触发要在 Cassandra 内部执行的更改（并且 Cassandra 保证在某些服务器上执行）。

对此的任何帮助都非常感谢。

谢谢，斯文。

代码：

如何使用 astyanax 客户端创建带有复合键的表。现在我已经用 cqlsh -3 创建了它，这就是它在 cli 中的样子：

这就是我期望它在 cqlsh 中的样子：

我让它使用存储为 blob 的复合键，这是一个问题。

我的代码

CF

KS

突变

cqlsh:KS>描述列族my_cf；

cqlsh:KS>从my_cf中选择*；

cqlsh:KS> select * from my_cf where key = 'THEKEY_B' order by timeid desc;

它在下面的 cassandra-cli 中看起来不正确吗？为什么它在 cqlsh 中不起作用？

cassandra-cli] 列出 my_cf；

我究竟做错了什么？(astyanax 1.0.6, cassandra 1.1.2) cqlsh>[cqlsh 2.2.0 | 卡桑德拉 1.1.2 | CQL 规范 3.0.0 | 节俭协议 19.32.0]

现在我只找到了“选择”的例子。

或者是否可以使用例如 MutationBatch？

我的专栏家庭是：

我有一个复合列，我可以像这样在范围的两端进行包含和排除

到目前为止很好，但是当我有一个没有复合名称的普通列族，其中名称是整数、十进制或字符串时，我该如何做同样的事情。现在我只有

但没有包容/独占的方法。

这个怎么做？

注意：整数和小数可以是二进制补码，因此它们可以以 fffff 开头，谁知道这些值有多长，因为它们可以像某人想要的那样大。

谢谢，院长

嗨，我正在使用 Astyanax 客户端在我的程序中使用 CQL 访问 Cassandra。我遇到的问题是，当我执行查询时，OperationResult 的行数设置为最大 10 000。我需要根据需要增加此限制。将 CQL 与 Astyanax 一起使用时无法进行分页。如果有人能指出我正确的方向，那将非常有帮助。提前致谢

我们如何使用 Astyanax 在 Cassandra 中检索一行？

我有一个需要在服务器端进行分页的 Web 应用程序，数据库是 cassandra。行键是一个 UUID，我一行中有几列，所以我试图对行键进行分页。

我已经制定了一个我并不完全满意的解决方案。问题是，当我根据从 UI 获得的搜索过滤器进行第一次搜索时，我不知道第一行的 UUID，所以我准备了一个查询，它给出了前 6 条记录，我存储了MAP 中的第 6 条记录并将其放入会话中，因此当用户从 UI 请求第二页时，我检索此键（UUID）并将其作为要检索的下一组记录的开始。我试图找到一种更清洁的方法。

我正在尝试使用 Astyanax 1.0.9 从复合列中提取并得到“InvalidRequestException（为什么：比较器的字节太多）”

这是我的CF：

我可以用 CQL 读取数据：

这是我的复合列 POJO：

这是我的测试驱动程序：（键空间在 junit @before 中设置，适用于非复合列）

它编译得很好，但在执行（）期间失败：

我尝试用 Long 替换 BigInteger，但得到了同样的错误。

任何建议我做错了什么？

谢谢查克

Stuck for hours on this one! Thanks so much for any insight :)

• Scala 2.9.2
• Astyanax 1.0.6 (also tried 1.0.5)
• Cassandra 1.1.4
• Using CompositeRowKey, CompositeColumnName
• No problem inserting into Cassandra
• Can read a row, ColumnList.size() returns correct count however any attempt to access ColumnList (i.e. iterate, access iterate ColumnList, getColumnByIndex(), getColumnByName(), etc) will throw the following exception:

Exception:

java.lang.RuntimeException: java.lang.InstantiationException

relevant stack trace:

Specifically:

Relevant sample code:

I've also tried this variation on the class:

我有一个包含多个列的列族：

但 Astyanax 只有：

如何使用 Astyanax 从上面的列族中读取数据？

thx 夹头

然而，我还有一种情况。在我的列族中，我有列的行，例如姓名、薪水和出生日期（出生日期），所有列都被索引。我想对 dob 进行范围基础索引搜索。如果您能告诉我我们该怎么做，我们将不胜感激。