问题标签 [cqlsh]

我试图在 CQLSH 中插入文本或某些字符串作为 blob 用于测试目的

它并没有真正起作用，因为在我这样做之后：

它说有0列......这有点出乎意料（因为它没有向我抛出错误）但我猜textAsBlob在cqlsh中不是一个东西。那么有人知道该怎么做吗？

架构：

我有点不情愿地发布了我的架构，因为我相信我的问题并不是关于这个特定的架构。我只想知道的是，如果有一列包含 blob，是否可以通过首先将字符串更改为 blob 然后将其插入 cqlsh 来在该位置插入字符串？

我正在使用 DSE 3.1.2 我正在使用 Pig 将一些预处理结果存储到 cql 中，我创建了一个表并启动了我的脚本，它适用于少量数据，当增加更多记录时它不会存储到 cassandra ，只有 90% 或输出存储到 cassandra。

这是我的脚本

现在我收到以下错误，90% 的记录被转储到 cassandra

如果我手动插入 cassandra，它执行的 lat 记录工作正常。

如果我将最终结果转储到 CFS，一切正常

我还尝试将数据转储到 CFS，然后从 CFS 转储到 Cassandra DB，这对我有用。请让我知道我错在哪里。我已经用复合键在 CQL 中创建了表，所以我想我们不需要提供任何比较器和验证器，因为我已经为列指定了数据类型。

现在这工作正常。

请让我知道我错在哪里。

我正在使用 Cassandra 2.0.3，我通过加载文件（源命令）通过 cqlsh 删除并重新创建一个简单表。在同一个文件中，我在新创建的表中插入了一些行。

大约每 3-4 次尝试一次，我在某些插入上得到 rpc_timeout。在这种情况下，我总是在集群的一个节点上出现此异常：

即使我在 cqlsh 中直接执行 INSERT，它也会因 rpc_timeout 而失败。通常大约一分钟后，插入成功。

我的节点是时间同步的（我在我的 PC 上使用了 3 个虚拟机），并且 LAN 在所有本地运行的虚拟机上当然都非常快。

我通过将 2 个节点添加到在单个节点上运行的现有 Cassandra 来创建集群。我的密钥空间没有使用复制：

这是我用来重现问题的文件的内容：

此 INSERT 进入集群的第三个节点，这是在创建表期间有时会失败的节点，但上述例外。

我在 Cassandra 有一张桌子：-

我已在表中插入数据：-

我想根据日期进行搜索（我正在使用 Java 客户端插入数据，其中 gp_date 只是日期，例如 2013-07-30）。我做了一个查询：-

我还需要包括时间部分来搜索。

但是比较应该仅基于日期（我想获取特定日期的记录，而不考虑时间）。我怎样才能做到这一点？有什么方法可以只比较日期部分吗？我正在使用 Apache Cassandra 2.0.7。

我正在尝试从具有 double 类型列的 Cassandra 表中获取 Double 值。我用 CQL3 语法创建了表：

我插入了一行：

当我做：

我知道该值为123.46

为什么要四舍五入？

谢谢

如何在 Cassandra中选择WRITETIME类型的列。list<text>尝试此异常时出现以下SELECT WRITETIME (column_name) from TABLE_NAME WHERE ID='1';
异常 com.datastax.driver.core.exceptions.InvalidQueryException: Cannot use selection function writeTime on collections

我正在关注http://wiki.apache.org/cassandra/GettingStarted

我做的第一件事cqlsh是

我究竟做错了什么？

我发现为什么我在 cassandra 的二级索引列中的查询会导致 rpc 超时。

这是我关于 cassandra 和桌子的详细信息

在这里，我们可以看到对二级索引列 host 的查询成功，但对 service_type 的类似查询得到 rpc_timeout 错误。

我无法找到它在此查询中出现 rpc_timeouted 的原因。

谢谢

关于更改分区器类型的问题：我想使用 sstableloader 将数据从旧集群复制到新集群。但旧集群使用的是 RandomPartitioner，而新集群使用的是 Murmur3Partitioner。您可能会问为什么不使用 COPY 命令将数据导出到 csv 并再次导入呢？好吧，我们有庞大的数据集，COPY 命令不起作用（所有其他节点的数据将聚合到一台机器上）。

是否可以将新的集群分区器切换到 RandomPartitioner，使用 sstableloader 进行数据复制，然后切换回来？（我尝试切换，但 cassandra 不会因此而重新启动......）

我将 rpc_port 设置为公共 IP 地址，现在我可以从外部服务器很好地连接到 Cassandra。

但是，我无法使用 cqlsh 从 Cassandra 服务器本身进行连接

我收到一个错误。Thar 是：

是否有配置，我可以更改为能够从服务器本身连接？