问题标签 [hector]

这里有一些关于在 JSF 2.0 中使用 Cassandra 的新手问题。我正在启动一个 Web 应用程序，并希望使用 Cassandra 作为后端。我的应用程序应该部署在不同的地区，因此相同的数据应该在所有地区都可用/复制。

我想了解有关最佳做法的一般信息。

我有以下设置：

• Maven2
• JSF 2.0（当前使用托管 Bean 和 JPA）
• 玻璃鱼 3.2.1

你会推荐哪个司机？

• 用datastax社区版实现的cassandra-jdbc驱动程序？
• 还是赫克托耳，这似乎是最先进的客户？

如果 Hector 我将如何在 JSF 项目中正确使用 Hector？

• Hector JPA 集成（找不到任何关于如何使用的信息）？
• 在没有 JPA 的情况下直接从 Managed Beans 使用 Hector？

如何在 JSF 2.0 Web 应用程序中最好地使用驱动程序？

• 托管豆？
• 单身豆？
• POJO？

（我对Java EE还不是很熟悉，但是在积累知识的过程中）

我将如何构造类/bean 以便可以汇集连接？

是否有使用 JSF/Java EE 或 JSF/POJO 的开源示例来查看在最佳实践中如何使用诸如 setup 之类的？

你对如何从头开始这样一个项目有什么看法？

我很感谢你能给我的所有提示。一个月以来，我一直在努力寻找足够的信息来开始这个项目。

每当我使用任何 Hector API 函数访问我的 Cassandra 数据库时，都会出现异常：

me.prettyprint.hector.api.exceptions.HectorException：所有主机池标记为已关闭。重试负担推给客户端。

我的服务器确实在后台运行 Cassandra 数据库。

我阅读了异常，它实际上没有记录。似乎异常是由于连接问题。

我如何解决它？

我正在使用 hector HOM 库来访问我的 cassandra 数据存储。这个库是用 java 编写的，在使用 Collections 时使用了一些反射。

我有一个 java 模型，其中包含我要检索的字符串列表。不幸的是，我得到以下异常：

我已经尝试显式创建一个 java.util.list 对象，但它仍然会导致同样的问题。这是我创建和持久化模型的代码：

该模型仍然很好，我可以在 cassandra 中看到它：

问题是当检索对象时，赫克托似乎不知道如何处理 scala.collection 类型。

有没有办法解决这个问题？

谢谢。

我可以创建一个具有列的新 SuperColumn - 没问题。我可以创建一个新列 - 没问题。但是如何向现有的 SuperColumn 添加新列？

我遇到了一个与此处列出的问题非常相似的问题：

单元测试后如何清理嵌入式 cassandra？

简而言之，我正在启动 Cassandra 来运行一些集成测试，但是当我的测试类运行时它们会失败，因为它们无法删除 Cassandra 生成的 CommitLog 文件。

我正在遵循那里给出的答案中的建议，即在启动时执行清理，但当时仍然无法删除文件（如果我通过代码进行调试，我当时也无法通过命令行或 GUI）。结果是我的第一个测试类通过了，但所有后续测试类都失败了。

更多详细信息：

• 我的同事在 OSX 上运行，没有这个问题；我在 Windows 7 上。
• 我已经尝试在 DOS 和 Cygwin 下以及通过 Eclipse 运行测试，在所有情况下都以我的本地用户和管理员身份运行。
• 我已经使用 Process Explorer 来确认除了单个 Java 进程之外没有任何东西可以处理相关文件。
• 我已经通过代码调试到 java.io.Win32FileSystem 中的本机调用，它无法删除文件。

我可以做些什么来确保 Cassandra 已关闭和/或删除其 CommitLog 文件？

谢谢！

我是卡桑德拉和赫克托的新手。

我想使用赫克托检索 Cassandra 中一行的所有列。在网上进行一些探索后，我得到了一些示例代码，但它需要范围或列名，例如，

在这里，我需要在 setRange() 方法中设置 Range，该方法检索此范围内的列。我们也可以在这个方法中设置开始和结束，但这也会给出特定范围的列。如果我没有设置范围，那么我需要将列名作为数组。

有没有办法获取特定行的所有列？我不想设置范围或列名，我只想要一行的所有列。因为在我的应用程序列中没有预定义。

或者有什么方法可以获取一行的总列数，以便我可以在 setRange() 方法中设置它？

谢谢。

这听起来像是一个愚蠢的问题，但我实际上查了一下，却找不到任何东西。我知道关闭数据库连接是一种很好的做法，这样您就不会意外地因未关闭的连接而使数据库陷入困境。但是，似乎没有任何 Hector API 函数可以“关闭”连接。

Cassandra 数据库完全有可能接受命令而不是连接。

我已经遵循了许多将数据插入 Cassandra 数据库的示例，并且每次我遇到有关未配置列族的异常时。

所以我查找了如何配置它们并发现

那没有配置列族。

我发现的所有示例都是没有任何上下文的片段，所以我不知道要导入或设置什么。此外，一些示例似乎混合了 Hector API v2 和原始的 Hector API，所以当我使用它们时，会出现“找不到类”或“找不到函数”编译器错误。

我一直在尝试使用 Java-Client 'HECTOR' 对存储在 Cassandra 中的数据运行简单的 map-reduce 作业。

我已经成功运行了这篇漂亮的博文中解释的 hadoop-wordcount示例。我还阅读了Hadoop 支持文章。

但是我想要做的是在实现方面有点不同（wordcount 示例使用一个脚本，其中提到了 mapreduce-site.xml）。我希望有人帮助我了解如何在分布式模式下运行 map-reduce 作业，而不是在 cassandra 数据上从“HECTOR”本地运行。

我的代码在本地模式下成功运行 map-reduce 作业。但我想要的是在分布式模式下运行它们并将结果作为新的 ColumnFamily 写入 cassandra 键空间。

我可能必须在某个地方设置它（如上面提到的博客文章中所述）
$PATH_TO_HADOOP/conf/mapred-site.xml
以在分布式模式下运行它，但我不知道在哪里。

这是我的代码

}

这是我收到的警告：

但是代码运行成功，执行 map-reduce 任务，但我不知道它在哪里写入数据。

编辑：我没有在 cassandra 中创建 columnFamily 用于输出。因此，它不是写作。所以现在唯一的问题是如何在分布式模式下运行它。

谢谢你。

是否可以在一个查询中从 Cassandra 中获取键为“1”的 col“a”和键“2”的 col“b”以及键“3”等的 cols“c”和“d”的值？

如果是，赫克托支持吗？

（所有这些列都在一个列族中并且属于同一类型。）