问题标签 [astyanax]

我的列族将数据存储在列名中，我想使用 Astyanax 对列执行范围查询。谁能建议如何做到这一点？

我正在尝试执行以下操作，但由于某种原因，由于 KeySerializer 的类型不匹配，我的代码无法编译。

编译错误如下"

这似乎只发生在 Scala 中，KeySerializers 不是字符串，ColumnSerializers 其他类型似乎工作正常？有解决办法吗？

我正在尝试使用 Astyanax 访问地图列类型。从我已经采取以下的例子。我正在循环这些行，并且可以从所有列中获取数据，除了具有数据类型 MAP 的列存储名称。我假设我需要遍历地图的元素以将数据放入我的对象中，但我不知道如何从列中获取地图数据。

我正在尝试 column.getValue 并尝试过 getByteBuffer 但都无法正常工作。我可以获得一个列对象，我看到有一个 ColumnMap 接口，但我不知道如何将数据放入扩展或使用它的对象中。我还看到了一个 MapSerializer 接口，但不知道如何实现它......

我对 getValue() 有点困惑，因为它需要一个 Serializer 作为它的第二个参数和一个默认值作为它的第三个参数。如何将 MapSerializer 作为第二个参数传递，或者我什至应该使用 getValue() 方法？默认值是 Map 中的键值吗？如果我想返回地图中的所有值，那该怎么办？谢谢。

我最近开始使用 Cassandra 数据库，我正在考虑使用Netflix client astyanax. 我进入了这个页面-

https://github.com/Netflix/astyanax

我想在克隆 git 存储库后，我可以简单地导入 maven 项目。

但是在克隆了上面的存储库之后，我找不到任何 pom.xml 文件吗？我是不是看错地方了？如果没有，那么我应该如何将所有 astyanax 客户端示例导入我的工作区并使用它。

基本上，我只是在尝试使用 astyanax 示例并学习如何使用 astyanax 客户端。

谢谢您的帮助。

我最近开始使用 Cassandra 数据库。现在我正在评估Cassandra client我们应该继续前进的过程。

我在 stackoverflow 上看到过各种关于 Cassandra 使用哪个客户端的帖子，但没有一个给出非常明确的答案。

我的团队要求我对此进行一些研究，并在 Java 中pros and cons为每一个提出一些建议。Cassandra Client API’s

正如我所提到的，我最近参与其中，Cassandra所以不太了解为什么某些人会选择Pelops client以及为什么某些人会与Astyanax其他一些客户一起去。

我了解每个 Cassandra 客户端的简要情况，我的意思是我能够完成这项工作并开始读取和写入 Cassandra 数据库。

以下是我目前掌握的信息。

卡桑德拉·阿皮斯

• Hector (Production-Ready)
  最稳定的 Java API，为黄金时段做好准备。

• Astyanax (The Up and Comer)
  来自 Netflix 的一个干净的 Java API。它不像赫克托那样广泛使用，但它很坚固。

• Kundera (The NoSQL ORM)
  JPA 兼容，当您想通过对象与 Cassandra 交互时，这很方便。
  这在某种程度上限制了您，因为您将无法拥有动态数量的列/名称等。但它确实允许您通过 ORM 移植，或将存储集中到 Cassandra 上以用于更传统的用途。

• Pelops
  我只简单地使用过 Pelops。这是一个直截了当的 API，但似乎没有它背后的动力。

• PlayORM（没有约束的 ORM？）
  我刚刚听说过这个。看起来它试图通过引入 JQL 来解决传统的基于 JPA 的 ORM 和 NoSQL 之间的阻抗不匹配。看起来很有希望。

• Thrift (Avoid Me!)
  这是“低级”API。

以下是我们在决定时的优先事项Cassandra Client-

• 首要任务是：低延迟开销、异步 API 和生产环境的可靠性/稳定性。
  （例如，可以在包装客户端的 DAL 中拥有更加用户友好的 API）。
• 连接池和分区感知是其他一些不错的功能。
• 能够检测到添加的任何新节点。
• 良好的支持（正如下面的院长所指出的）

任何人都可以提供一些想法吗？每个人的任何利弊以及Cassandra Client哪些客户可以满足我的要求也将有很大帮助。

我相信，主要是我将围绕Astyanax client or New Datastax client that uses Binary protocol我猜想基于我到目前为止的研究。但是没有特定的信息来支持我的研究并将其呈现给我的团队。

Astyanax 客户端和 New Datastax 客户端（使用新的二进制协议）之间的任何比较都会有很大帮助。

这将对我的研究有很大帮助，并且会从过去使用过不同客户的不同人那里获得很多关于这方面的知识。

我在由 Priam 管理的 Cassandra 集群上运行在 Amazon 上的 Java 应用程序。

我们使用 Amazon 的 Elastic Map/Reduce 服务，在某个时刻，当我运行 EMR 并尝试在 Cassandra 上插入一些数据时，我得到了一个异常：OperationTimeoutException。

这些是我在 Astyanax 上创建 Cassandra 池时传递的配置参数：

完整的堆栈跟踪：

所以我不知道解决这个问题的方向是什么，因为问题可能出在 Astyanax 池配置、EC2 机器配置（内存增加？）、Priam 配置或 AWS 上 Cassandra 或 EMR 服务所需的其他配置在我的代码中......任何提示？

遵循堆栈跟踪：

我已经在本地设置了一个节点集群。现在我正在尝试从 Cassandra 读取数据。我是 Astyanax（Cassandra 的 Netflix 客户端）的新手。

目前我所看到的是 - 您可以在 rowkey 上请求数据基础。基于rowkey的含义我可以检索所有不是我想要的列。

但我正在寻找的是 - 我将拥有 rowkey 和几个 columnNames。因此，基于该行键，我只需要检索这些列。像这样的东西-

以下是我基于行键检索所有列名的方法。如何在给定行键的情况下仅检索选定的列？

在上面的代码中，Collection<String> columnNames我想要请求的列名很少。

谁能告诉我我需要在上述方法中进行哪些更改？

我想将 Astyanax 包含在我的项目中。我从 github 签出代码并用“gradlew build”编译它。我不熟悉gradle。

我将 Astyanx jar 文件手动包含到我的项目中。当我运行它时，它抱怨缺少 Jar。

我想知道，在哪里可以下载 Astyanax 的所有依赖包？

我正在使用 Cassandra 开始一个新项目（并计划使用最新的稳定 (1.2.x) 版本）。我尝试了几个不同的 Java 库，比如Hector、Astyanax、Cassandra-jdbc...

其中，（简而言之）我的选择是Astyanax。但后来我也找到并尝试了 DataStax 的 Java 驱动程序，它支持新的 CQL 二进制协议，如果你只使用 CQL 会更干净。看来 1.0.0 GA 版本即将发布。

你会推荐哪一个？谢谢。

Problem Statement:-

I am trying to insert data into Cassandra database. I am using Netflix/Astyanax client for this.

Below is the code which will upsert data into Cassandra database using Astyanax client.

In my below method, it accepts two parameter. One is the userId which I will be using as the RowKey and attributes map which will contain, column name as the key and it's column value as the value in the map.

Now how can I use Astyanax client to upsert data into Cassandra database using the below method which accepts those two parameters?

I am mainly concern about attributes Map. How should I use that map to upsert data into Cassandra database?