问题标签 [pelops]

目前我正在使用客户端（Pelops）将 UUID（词汇和时间）插入 Cassandra。我还没有实现用 Pelops 删除它们的工具；我正在测试和完善插入机制。

因此，我想使用 CLI 删除测试 UUID 值。但是，似乎我无法使用该del命令删除 UUID 行键和列。有什么我想念的吗？我必须使用assume asUUID 行键列出列族中的行，但删除显示的行键不会删除条目。

我可以在没有 UUID 值的情况下查看列assume as（前提是它们不包含在具有 UUID 键的行中），但我也无法从 CLI 中删除它们。不能从 CLI 执行此操作，还是我忽略了什么？

在 Java 中使用 pelops 时有没有办法捕获连接错误？我有以下代码，但由于某种原因，我没有进入我的 catch 块。

这可能真的很容易，但我似乎无法让它发挥作用。我看到了异常，但是我无法捕捉到这个？有人可以引导我朝着正确的方向前进吗？

谢谢！

编辑 - 在 Eclipse 控制台中返回异常...

“org.apache.thrift.transport.TTransportException：java.net.SocketException：软件导致连接中止：套接字写入错误”

在处理某些批次后出现此错误（即，将一些数据插入 cassandra） m 使用 pelops 客户端进行 casssandra 一致性级别为 ONE

谢谢，萨玛斯

m 使用 pelops 与 cassandra 交谈，并且想知道当 m 尝试插入 1 GB 数据时，它在服务器上的性能比本地性能要慢。我正在尝试批量插入，即 m 在 mutator.writecolumn 中创建大约 2000 列的批处理，并且使用 mutator.execute m 插入 0.1 GB 的数据处理时间超过 25 分钟。我想知道是否有任何解决方案或者这是 cassandra 的正常性能？

已经创建了 3 个节点的集群。cassandra 7.4 pelops 节俭 0.5

感谢和问候萨玛斯

我编写了一个“人口普查”程序来遍历列族中的所有行，并在每一行中计算列，记录最大值和行键。我在 Hector 客户端上花费了更多时间，但也编写了一个 Pelops 客户端进行测试。

基本流程是使用 RangeSlicesQuery 遍历行，然后在每一行，使用 SliceQuery 遍历并收集统计信息。在 Pelops 中的工作方式类似，只是 API 不同。缺点是必须手动进行缓冲，为行和列选择缓冲区大小......我当前的数据是 1200 万行，最大列数 ~25K，所以是的需要一段时间......在我目前的配置中，我得到> 每秒 25K 行。

寻找改进和发现 Hector 的 CountQuery 的方法（我假设它使用 Thrift 客户端 get_count()）。认为只迭代键（使用 RangeSlicesQuery.setReturnKeysOnly()）会更快，然后在每个行键上重新使用 CountQuery，我修改了代码。

它不仅慢，而且慢了 30 倍！（每秒仅处理 900 行）...

有没有更好的方法来计算列？

我有一个 Java 和 Scala 项目，我使用 maven 来编译它。Java 类使用 Pelops 访问 Cassandra 数据库，一切都很好（maven 编译整个项目），但是当我尝试从 Scala 对象访问 Cassandra（使用与 Java fil 中相同的导入）时，maven 给了我这个错误：

这是什么意思，我该如何解决？我不明白为什么从 Java 文件可以工作，但不要从 Scala 源...

这是代码：

结果如下：

但我不明白为什么它给了我异常，linkID 和主题字符串具有正确的值。

PS：cassandra的版本是1.0.0，pelops的版本是1.3-1.0.x-20111021.060203-2

有人能帮我吗 ？

当我尝试使用 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

调用以下函数会导致异常

错误堆栈如下：

我正在使用 Pelops 与 Cassandra 一起工作。我想使用 mutator 插入批量数据。当我插入大约 20000 条记录时，它可以正常工作，但是当我超过记录数时，它会显示“对等方重置连接：套接字写入错误”。我正在编写以下代码。

但它适用于一些有限的记录。

我收到以下错误：

我试图弄清楚如何使用 Pelops 批量删除 Cassandra DB 中的行。

理想情况下，我可以指定需要删除的行的 KeyRange。这对我的目的来说很好。

然而，我（尽管很简短）的研究让我相信这目前是不可能的。RowDeletor 只接受 rowKey，而不接受 KeyRange。这些发现正确吗？

我应该能够使用我的 List 函数之一的修改版本以编程方式完成它，但是，KeyRange 会更可取。