问题标签 [hector]

我有一个 3 机器 Cassandra 集群，它使用机架不感知放置策略，复制因子为 2。

列族定义如下：

不幸的是，经过几天的生产使用，我得到了一些不一致的计数器值：

查询副本 1：

查询副本 2：

由于标准读取修复机制似乎无法修复值，因此我尝试使用 nodetool repair 强制进行反熵修复。它对计数器值没有任何影响。

数据检查显示计数器的较低值是正确的，所以我怀疑 Cassandra（或我用作 API 从 Java 调用 Cassandra 的 Hector）重试了一些增量。

任何想法如何修复数据并可能防止这种情况再次发生？

有人可以强调 Hector 的批量突变和使用 Hadoop 作业将数据加载到 Cassandra 的优缺点吗？

我知道在赫克托您可以执行以下操作：

在 Hadoop 中，您可以使用 MR 作业将数据加载到 Cassandra。

我正在寻找使用或不使用它们的原因。谢谢！

大家好，我正在尝试通过 Hector 将模式加载到 Cassandra 0.8.2 数据库中。

我想添加一个列族（在特定的键空间中）并通过 Hector 指定其名称、比较器类型、键验证类和默认验证类。

我在这里查看了文档： https ://github.com/rantav/hector/blob/master/core/src/main/java/me/prettyprint/hector/api/factory/HFactory.java

对于执行此操作的函数，但似乎我必须已经创建了列族（通过 Cassandra CLI）来指定默认验证类和通过 CLI 创建列族时的键验证类。我在这个假设中正确吗？我错过了任何方法吗？是否可以通过 Hector 更改 Cassandra 列族的默认验证类和键验证类？

我正在尝试获取我正在使用的当前键空间中的所有列族，因为我想摆脱错误：

InvalidRequestException(why:[column family] already exists in keyspace)

我的逻辑是获取当前键空间中的所有列族并检查特定列族是否出现在返回的列表中。所以，我尝试：

KeyspaceDefinition keyspaceDef = HFactory.createKeyspaceDefinition("test");

...

List<ColumnFamilyDefinition> lsCf = keyspaceDef.getCfDefs();

好像创建有问题

List<ColumnFamilyDefinition> lsCf = keyspaceDef.getCfDefs();

我做了一个System.out.println(keyspaceDef.getCfDefs())，它回来了

[]

一个空列表 - 这是我所期望的。我无法理解的是为什么List<ColumnFamilyDefinition> lsCf = keyspaceDef.getCfDefs();不正确。Eclipse 不同意这一行的“列表”部分。除此之外，他的代码似乎是正确的。有人可以帮我理解为什么这条线是错误的或者我的方法是否错误吗？

这是完整的代码片段：

错误：

这个简单的应用程序需要一个带有标题的逗号分隔文件并放入 Cassandra。它适用于小文件，但是内存只会上升，直到内存不足异常杀死它。

我错过了什么？

首先，我读到了这个。

我无法让 Cassandra 重新启动并运行。我使用 Hector 作为我的客户端来连接到 Cassandra 0.8.2 的实例并加载我的模式。通过 Hector，我使用 2 个不同的类来创建 2 个不同的列族 - Articles & TagsArticlesCF。

通过主类，我创建了一个名为“Articles”和“TagsArticlesCF”的列族，如下所示：

这是我的列族的外观/创建方式的示例：

我正在尝试将完整的模式添加到 Cassandra 中，该模式将支持我计划对加载的数据执行的查询。我运行了几次 main 方法将新的列族加载到数据库中。在多次运行 main 方法并调整了一些东西（检查列族是否已经在 KeyspaceDefinition 中）之后，Cassandra 的运行实例停止了。

我对使用 Hector/java 的一些事情感到好奇：

1. 我计划有 10 个左右不同列的列族（以支持不同的查询）。最好的做法是组织我的课程，以便我为每个列族都有一个课程？

2. KeyspaceDefinition 和 Keyspace 之间到底有什么区别？为什么要区分？

我们试图获取 Cassandra 的新实例，这就是我们遇到的问题。我正在努力更好地了解发生了什么，任何评论和帮助避免这些类型的错误将不胜感激：

...（更多相同）...

...（更多相同）...

谢谢！

有什么问题？

我在哪里可以找到这方面的样品？

我的大部分代码使用 ColumnFamilyTemplate 对数据记录进行 CRUD，见下文。定义复合键后，我是否仍可以使用 ColumnFamilyTemplate 访问具有复合键的数据？

当我尝试删除时使用 hector（cassandra 客户端），它会删除列……但留下行键……有谁知道为什么，我怎样才能删除该行键？

问：我使用 hector（cassandra 客户端）并将 UTF8 类型的值存储在列中，在客户端我使用 hector 的 StringSerializer 来序列化/反序列化值。它适用于普通字符串（仅字母数字字符）......但是当有非字母数字字符（如 -> ， ; / ）时，它会对其进行序列化..但无法反序列化..其他人看到过这个问题吗？