问题标签 [datastax-java-driver]

我有一个这样定义的 CQL 表：

假设我插入这样的值：

我将如何检索插入数据的 TTL？通常，如果有一个 CQL 列不是主键的一部分，那么我可以使用如下语句：

但是由于只有主键列，因此功能喜欢ttl并且writetime不起作用。除了向不属于主键的表中添加额外的“虚拟”列之外，我如何获得 TTL？

我正在尝试为 Cassandra DB 使用 Datastax Java 驱动程序API，并且我有一个具有 getList 函数的行对象：

我的问题是我如何实际使用它？我不知道如何制作Class<T> elementsClass类型参数。在我的例子中，结果应该是一个浮点列表（基于我正在使用的 Cassandra 模式）。

我最近开始CQL对使用 Datastax Java 驱动程序很感兴趣。以前，我使用的是column family代替 table，我使用的是 Astyanax 驱动程序。我需要在这里澄清一些事情-

我在我的生产集群中使用下面的列族定义。而且我可以即时插入任意列（及其值），而无需实际修改列族模式。

但是在阅读完这篇文章之后，看起来 - 每当我要插入一个新列时，我都需要更改架构，这不是我想要做的......因为我相信 CQL3 需要存在列元数据...... .

如果我使用 Datastax Java 驱动程序，是否还有其他方法可以添加任意列及其特定值？

任何代码示例/示例都将帮助我更好地理解.. 谢谢..

我最近开始Cassandra在我们的Production environment. 我们有一个24 node clusterwith replication factor of 4。意义2 copies将在那里each datacenter。所以这意味着我们有一个单一的交叉结肠集群，24 nodes其中12 nodes in SLC colo和12 nodes in PHX colo。

我Astyanax client目前正在使用将数据写入Cassandra database. 而且我知道 Astyanax 客户端具有此功能，可以在其连接池中自动发现 PHX colo 或 cassandra 的 SLC colo 中的所有节点，但不是所有节点。

在 Astyanax 中，我们可以使用如下所示的内容 -

现在我们计划使用 Datastax Java 驱动程序。而且我不确定Datastax java驱动程序是否具有此功能，是否仅针对特定数据中心而不是所有数据中心自动发现其连接池中的所有cassandra节点？

我目前正在尝试将 datastax 核心 java 驱动程序转换为 OSGi 等效包，但不断出现错误。

我使用的版本是

任何指针都受到高度赞赏。有没有人致力于将 datastax 转换为 OSGi 包？

我在 cassandra 键空间中有一个类型为 timeuuid 的列。当我尝试从 java 代码中插入记录时（使用 DataStax java driver1.0.3）。我得到以下异常

这是我的示例代码：

我也尝试过使用UUIDs.timeBased()而不是now(). 但我得到了同样的例外。

任何有关如何插入/读取timeuuid数据类型的帮助将不胜感激。

我打算使用 Datastax Java 驱动程序来写入 Cassandra。我主要对Datastax Java 驱动程序的特性Batch Writes和Asycnhronous特性感兴趣，但我无法获得任何教程来解释我如何将这些特性合并到使用 Datastax 的以下代码中Java驱动程序..

在下面的代码中，我正在使用 Datastax Java 驱动程序创建与 Cassandra 节点的连接。

任何人都可以帮助我如何将批量写入或异步功能添加到我的上述代码中。谢谢您的帮助。

我正在运行 Cassandra 1.2.9

我正在尝试使用 datastax 驱动程序将地图插入 cassandra。地图有价值

Intel(R) Core(TM) i5-2520M CPU @ 2.50GHz

如果我尝试使用查询生成器插入值，我会收到语法错误，指出“@”没有可用的字符。

如果我直接使用 insert 语句构造 cql3 注释并将映射构造为字符串，它将被插入。关于这个问题的任何想法

我正在使用 cassandra1.2 和 datastax java 客户端 1.0.3 使用来自 datastax 的 java 客户端示例我创建了一个类，它将返回会话

我使用 getDatastaxSession 函数来获取会话并在数据库中进行一次插入。前几个插入工作正常，但一段时间后我得到空指针异常，如下所示：

此异常是否由于 Session 为空/超时？如果我以错误的方式创建或管理会话，请告诉我。或者，如果我的代码有任何问题，请告诉我。

如果我像以前一样在 Cassandra 中创建了一个这样的列族，我使用的是基于 Thrift 的客户端。

那么我可以使用具有异步/批量写入功能的 Datastax Java 驱动程序插入到上面的列族中吗？

我将使用 INSERT 语句插入到上面的列族中吗？这可能使用 Datastax Java 驱动程序吗？

我的印象是，我只能使用 Datastax Java 驱动程序插入基于 CQL 的表中，而不是列族设计表中......