问题标签 [astyanax]

我们正在以 Cassandra 作为数据库开始一个新的 java web 项目。该团队在 RDBMS/JPA/Hibernate/Spring 方面非常有经验，但对 NoSQL 世界还是很陌生。我们希望以尽可能简单的设置开始开发。 Hector似乎是连接 Cassandra 的首选和最受欢迎的选择。但是，Netflix 最近提供了Astyanax，它起源于 Hector。使用过这两种技术的任何人都可以分享他们的经验吗？我正在寻找简单的设置、良好的文档和简单/干净的用法。也欢迎对其他 api 提出建议。

我想将一些文件流入和流出 cassandra，因为我们已经使用它而不是设置完整的 hadoop 分布式文件系统。是否有任何异步放置在 atyanax 或 hector 中，我在完成时提供回调，这样我可以避免 1000 次调用的 1 毫秒网络延迟，因为我写了 1000 个条目（在几行和几列之间拆分，所以它是流式传输的并行到几台服务器，然后所有响应/回调在完成流式传输时返回）。Hector 或 astyanax 是否支持这一点？

看起来 astyanax 支持查询回调，所以我想我可以使用主键将文件流回 astyanax？

谢谢，院长

我正在寻找一个像这样的数据模型。在这个数据模型中，我使用复合键。我知道如何制作复合键。但不知何故，在这种情况下我无法做到。

我想在 Astyanax 做这个。请建议我怎么做。

提前致谢

有没有人想出一种方法来保护 Cassandra 和 Astyanax 客户端之间的通信？SSL 最好能够进行客户端证书身份验证 + 加密......

是否可以使用 Hector 或 Astyanax 通过复合键获取行（在多列中，而不是序列化为一列的行）？

在 cqlsh 我创建了简单的列族：

根据Cassandra 开发人员中心，行由 x 作为键存储，其余存储在列中。

我不知道如何为给定的 x 和 y 获取列切片。

在那个 cql 中执行 cql

给我行：

行(2,ColumnSlice([HColumn(x=2)]))

行(10,ColumnSlice([HColumn(x=10)]))

和控制台 cqlsh 给出：

x | 是 | val1 | val2

-----+-----+-------+------------

2 | 1 | v1_1 | v2_1

10 | 27 | v1_4b | v2_4b

10 | 91 | v1_4a | v2_4a

任何人都设法在任何 cassandra 客户端的 java 中做到这一点？我可以为此使用节俭，还是只有 cql 的功能？

我正在尝试将 Astyanax 用于带有 Java 的 Cassandra。我在https://github.com/Netflix/astyanax/wiki/Getting-Started尝试了这个例子。我有我刚刚从这个链接复制的代码：

但是当我运行它时，我遇到了一个异常：

谁能告诉我这有什么问题？也没有适当的文档可用于此。所以，你能不能帮帮我。甚至给我一些链接，我可以在其中获得更多示例。

从 Astyanax 的入门页面：

所以键是一个字符串，列值也是一个字符串。但后来：

最后一个 putColumn 语句使用“30”（int 值）作为列的值。
这是怎么可能的，因为前面的声明表明列值是一个字符串？

我需要将 GCGraceSeconds 设置为 0，因为我只有一个节点，但我找不到可以为此设置值的位置。是否可以从 astyanax 设置或在某些设置文件中设置？

我正在尝试使用 astyanax 连接到本地 cassandra，但不断收到 PoolTimeoutException。我可以使用 cli 或 hector 客户端连接到 cassandra。知道我在做什么错吗？

谢谢。

我的代码：

例外：

我需要在这些类型的每一列中创建 3 个具有复合名称的列族

1. Col Family 1 需要 UTF8 和 byte[]
2. Col Family 2 需要 BigDecimal 和 byte[]
3. Col Family 3 需要 BigInteger 和 byte[]

如何在 astyanax 中创建列族。我看到一个 setComparatorType(String) 但我希望比较器是 UTF8、BigDecimal 或 BigInteger（即复合键的第一部分）......我不在乎 byte[] 的顺序是什么，这样可以是随机的......真的不在乎。

另外，我是否需要在 astyanax 的 ColumnFamilyDefinition 对象上设置任何其他内容才能创建此列族？

另外，我看到了将值与自创建的带注释的复合类型一起放置的示例。我假设我只是调用 colMutation.putColumn(compositeTypeInst, value, theTime) 将其放入 cassandra？

谢谢，院长