问题标签 [spring-data-cassandra]

如何将spring与cassandra集成以及如何与多个表一起使用。请举例说明。

我读到了easycassandra

提前致谢

我正在使用 Spring Data Cassandra 1.0.0。我设法坚持并读回我的实体。但是，现在我想做一个只返回实体的 1 个字段的查询。

这是我尝试过的：

cassandraOperations是一个CassandraTemplate实例。

所以我只message_time从data_message表中选择。这是一timestamp列，因此我将 a 传递Date.class给该select()方法，但这会产生以下异常：

我应该如何只查询 1 个字段？

PS：如果您知道执行此查询的更高效的方法，我也很乐意听到。

我是spring-data-cassandra第一次设置并有这样的课程：

这在启动时给了我一个错误：

来自spring-data-jpa背景的简单注释以前就足够了Location。@Embeddable看起来这不适用于spring-data-cassandra. 如何使用复合实体spring-data-cassandra？

是否必须自己注释location并@Transient进行一些序列化？我试图用注释我的班级，@Persistent但收到关于PrimaryKey丢失的错误Location。我无法理解为什么需要主键...

想象以下情景：Spark 应用程序（Java 实现）正在使用 Cassandra 数据库来加载、转换为 RDD 并处理数据。此外，该应用程序正在从数据库中传输新数据，这些数据也由自定义接收器处理。流式处理的输出存储在数据库中。该实现使用与数据库集成的 Spring Data Cassandra。

卡桑德拉配置：

DataProcessor.main 方法：

预计初始加载会有大量数据。出于这个原因，数据在 rddBuffer 中被分页、加载和分发。

还有以下可用选项：

1. Spark-Cassandra 示例（https://github.com/apache/spark/blob/master/examples/src/main/scala/org/apache/spark/examples/CassandraCQLTest.scala），尽管文档数量最少对于这个例子。
2. Calliope 项目 ( http://tuplejump.github.io/calliope/ )

我想知道将 Spark 与 Cassandra 集成的最佳实践是什么。在我的实施中遵循的最佳选择是什么？

阿帕奇星火1.0.0，阿帕奇卡桑德拉2.0.8

我正在使用 spring data cassandra，并且我有一个如下定义的@Table。

在我的 dao 代码中，我正在设置枚举值并进行保存。但我得到一个错误。

但我在执行保存操作时看到报告了此错误

查询生成器未知类型的无效值 CONNECTOR...

spring Data 是否不处理 cassandra 的枚举到字符串数据类型的转换？

指向这里失败的任何指针。

我正在使用 spring-data-cassandra 模块。

我有一个使用 @Table 注释的带注释的 bean 和一个使用@PrimaryKeyClass

主键类有 5 个主键列（2 个分区和 3 个集群）。我的 2 列具有 name 属性，即：

使用 CassandraTemplate 插入操作时，一切正常，但是当我使用cassandraTemplate.deleteAsynchronously(List<entities> list)列名时，不使用 name 属性解析列名，而是维护字段名。

我尝试对单个对象使用常规删除操作，并尝试使用 forceQuote = true 属性都没有帮助。

以前有人遇到过这个问题吗？

我正在使用 spring-data-cassandra 但我在 CassandraTemplate 中找不到处理计数器的方法。

我在日志中收到此警告：

WARN [Native-Transport-Requests:17058] 2014-07-29 13:58:33,776 BatchStatement.java（第 223 行）[keyspace.tablex] 的准备好的语句的批次大小为 10924，超过了 5804 的指定阈值 5120。

spring data cassandra中有没有办法指定大小？

Cassandra 2.0.9 和 Spring Data cassandra 1.0.0-RELEASE

如果我在 spring-data-cassandra 项目中根本没有设置任何读/写一致性级别，那么我的读取一致性级别是多少？写呢？

（我在这里问过这个问题，但谷歌组现在被锁定了）

在存储库上是否findAll()在返回之前获取所有结果？我问这个的原因是因为我OutOfMemoryException在一个相当大的数据集（磁盘上约 15 GB）上调用它。由于它返回了一个Iterable<T>我期待它进行后台批处理，以便我可以轻松地遍历整个数据集。

如果该方法不允许更大的查询结果，我想我会在 JIRA 上提出问题。