问题标签 [phantom-dsl]

我正在phantom按照 wiki 上的布局 tut 从外包人员那里尝试。

我正在使用测试模型：

和：

该ListColumn[String]()论点this被标记为错误，我认为我什至不应该费心构建。预期CassandraTable[String, User]而不是this.

我正在使用版本 1.29.6

我使用的版本与 wiki 示例不同吗？还是缺少其他东西？

对 Cassandra 来说是全新的。尝试在 Cassandra 中使用phantom-dsl. 我收到此错误消息。

我不确定是否是Connectorinphantom-dsl或ClusterBuilderin的问题datastax-driver。

连接器.scala

CassandraSpec.scala

两个相关问题

1) 目前，与 C* 的会话是以惰性方式建立的 - 也就是，仅在第一次访问任何表时。
相反，我们希望在应用程序启动后立即建立会话（以防出现连接问题等）。最好的方法是什么？我应该在我的启动代码中获取一个会话对象吗？

2）然后我将如何监控连接的健康状况？我可以打电话

但我不确定它会完成这项工作。

这是设置默认（读写）一致性级别的正确方法吗 val connector: KeySpaceDef = ContactPoints(hosts, port).withClusterBuilder { builder => builder.withQueryOptions(new QueryOptions().setConsistencyLevel(ConsistencyLevel.QUORUM)) }.keySpace("test")

当我们在一个查询中增加每行要更新的列数时，cassandra 的性能会提高还是降低。

假设我们有一个最好的表组（例如 FB 组）：

1/ 表组（groupId Int, name String, members Map(userId -> roles)）

或者

2/ 表组（groupId Int, name String, admins Set[Int], moderators Set[Int], simpleMembers Set[Int]）

我们假设用户可以拥有版主和管理员角色，因此在删除此用户时，我们必须在第二种方法中更新 2 列管理员和版主，而在第一种方法中，我们必须只更新列成员。

Phantom DSL 有没有办法指定每个分区缓存的行数？我可以：

.create.ifNotExists()。with（缓存 eqs Cache.RowsOnly()）

但我找不到如何指定缓存条件的方法，例如：所有键 + 每个分区 500 行。

我正在使用带有 Datastax Cassandra 驱动程序的 Phantom-DSL 获得 Cassandra 超时。但是，Cassandra 似乎并没有超载。下面是我得到的例外：

以下是我在这段时间内从 Cassandra Datadog 连接器获得的统计数据：

您可以在顶部中心图上看到我们的读取率（每秒）。我们的 CPU 和内存使用率非常低。

以下是我们配置 Datastax 驱动程序的方式：

我们的nodetool cfstats样子是这样的：

当我们运行时cassandra-stress，我们没有遇到任何问题：正如预期的那样，我们每秒获得稳定的 50k 读取。

每当我进行查询时，Cassandra 都会出现此错误：

为什么我们会超时？

编辑：我上传了错误的仪表板。请看新图。

我想定义一个新的列/转换器来将案例类编组为原始类型，然后使用幻像 dsl 再次返回。

在 slick 3.1.1 中，我可以轻松做到这一点：

这使我Id可以在一个灵活的查询中使用任何地方，它将被隐式地来回转换。

我试图通过扩展AbstractColumn（和其他）来导出我自己的列和转换，但没有运气。

我如何在幻像 dsl 中做到这一点。

我正在使用 Phantom 库将 Scala 代码中的行插入 Cassandra。

所以基本上我创建了一个扩展 CassandraTable 的类，然后我从幻像库中获取所有创建、更新方法。

我想知道的一件事是它如何生成它的 INSERT 语句。它是否会生成条件更新语句（如 INSERT IF NOT EXISTS）的 vanilla INSERT 语句。

我正在尝试使用 phantom 来处理我的 Cassandra 这是我学习如何使用 phantom 的示例（感谢 Thiago）

https://github.com/iamthiago/cassandra-phantom

我可以成功运行“SongTest”。

database.create但是我在我的 scala 主对象中运行时遇到了一些麻烦。'scalatest' 中的相同代码成功运行。但在我的 scala 主要对象中，它失败了。这是我的源代码

这是我的错误