问题标签 [phantom-dsl]

我正在使用 Phantom 1.28 和 Cassandra 3.7。

我有一个 Java 8 案例类LocalDateTime：

在虚拟模型中：

编译错误：

我喜欢坚持 Java 8 LocalDateTime，我该如何解决OptionDateTimeColumn需要 joda 时间？还是有更好的方法？

我的案例类包含如下枚举参数：

如何像本例那样对这种情况进行建模？

提供的任何代码示例都会有所帮助。

我的模型上有一个更新方法，它接受一个带有选项类型的类，我想构造一个更新语句，其中包括一个动态 SET，具体取决于哪些字段具有值。使用 Phanton-dsl 1.5 我有类似的东西；

现在我正在尝试迁移到 Phantom-dsl (1.27) 的最新版本，但我在仅使用 dsl 进行等效操作时遇到了麻烦。由于任何字段都可能为 None，因此构造第一个 modify() 然后使用任意数量的 and() 进行该操作被证明是困难的。

任何有关如何处理此问题的建议都会有所帮助。

我有来自 SparkStreaming 的数据流。我需要处理并最终想将数据存储在 Cassandra 中。所以，早些时候我试图使用 SparkCassandra 连接器。但它没有提供对工作人员的 SparkStreaming Context 对象的访问权限。所以，我必须使用单独的 cassandra-scala 驱动程序。因此，我最终得到了phantom。现在，我的问题是我已经在 cassnandra 中定义了列族。那么，我如何从 scala 中进行选择和更新查询。

我已经关注了这些文档链接1 ，但我不明白为什么我们需要在客户端（scala 代码）端给出表定义。为什么我们不能只是给予Keyspace，ClusterPoints并ColumnFamily完成它。

我在网络和 API 上挖掘了几个小时，但似乎找不到关于这个主题的正确信息。（这真的很奇怪，因为 phantom 在最新 cassandra 的功能方面被宣传为最新）如果 phantom 确实支持物化视图，我在哪里可以找到有关它的更多信息以及如何使用它？

我是 cassandra 的新手（几天前开始根据自己的兴趣学习）并为以下问题寻求帮助。

我有一个 Cassandra 表“用户”和一个 ListColumn“兴趣扩展 ListColumn [String]”。现在，我想获取所有感兴趣的用户，比如“玩”。

比如：从用户中选择interests.contains("playing")！我扫描了 ListColumn api，但找不到任何东西。此外，在谷歌搜索但没有这样有用的帖子。

任何帮助，请...在此先感谢:)

我已经定义了一个自定义 Cassandra 类型和一个表，例如：

如何在 Scala 的 Cassandra 表定义中定义此用户类型？

如何实现自UserColumn定义UserType？我检查了列实现的 Phantom 代码，但任何示例和/或解释都会很棒。

I am using phantom 1.29.4 and scala 2.11.8, trying to do hands on cassandra with scala. I have my datamodel like below...

Now, I am getting a type mismatch error ("expected com.websudos.phantom.dsl.DateTime actual java.sql.Timestamp" which is obvious)... Now my question is how do I convert Timestamp to DateTime (because, I have my service layer in different sub project and I don want to add all phantom dsl jars there) or provide current time to Datetime?

I have also tried providing a implicit conversion like below...

but still no luck...

Please help me guys as I am new to cassandra... Thanks...

我正在尝试使用 Phantom 创建以下 Cassandra 表

所以我希望能够通过itemId. 我希望他们被订购similarity。我设置anotherItemId为PrimaryKey因为itemId, similarity复合键不会是唯一的。但我收到以下错误：

这个例子表明使用PartitionKey,PrimaryKey和ClusteringOrder是可能的。我究竟做错了什么？

我目前正在将 Phantom DSL 集成到一个小型 Play 应用程序中。由于我们计划在 Docker 环境中运行应用程序，因此我在本地机器上使用 Docker Compose 来测试应用程序。

但是，当同时启动 Cassandra 实例和 Play 应用程序时，它无法连接或运行，因为 Play 应用程序在 Cassandra 之前可用。

我目前的连接器设置如下：

像这样初始化数据库

还有我的游戏！控制器使用 CassandraDB 对象调用数据库

第一次尝试连接到数据库会导致预期的 NoHostAvailableException

之后的任何请求都将引发以下异常：

一旦发生这种情况，需要手动重新启动应用程序才能使其正常工作。

在等待 Cassandra 容器完全初始化工作正常时，这似乎并不理想，我希望在连接失败后重试