问题标签 [phantom-dsl]

有没有在 phantom-dsl 中实现计数器操作的例子？

已检查：

http://outworkers.com/blog/post/a-series-on-cassandra-part-3-advanced-features

https://github.com/outworkers/phantom/wiki/Counter-columns

https://github.com/outworkers/phantom/blob/develop/phantom-dsl/src/test/scala/com/websudos/phantom/tables/CounterTableTest.scala

有点寻找此信息的 phantom-dsl 版本：

https://github.com/Netflix/astyanax/wiki/Working-with-counter-columns

下面是部分实现。它提出了两个问题：

1. 我不确定如何从应用程序中获取值并在计数器表的计数器列中实现增量计数器操作。

2. 如何更新与同一条目相关的表中的行，其中表具有不同的行数和键数。

在thiagos 示例中，这两个表；'songs' 和 'songs_by_artist' 都具有相同的行但具有不同的分区（主键/集群列）

我不确定在 phantom-dsl 中如何更新与相同条目相关的行，例如下面的“records”和“record_transaction_counts”表。

例如

RecordTransactionCounts.{hash, time} relates to Records.{hash, time}

这是对这个问题的扩展：

如何使用 phantom-dsl 增加 Cassandra 计数器列？

这个问题也被问到了这里。

在Thiagos 示例中，这两个表；'songs' 和 'songs_by_artist' 都具有相同的行但具有不同的分区（主键/集群列）

这意味着在SongsService内的两个表中插入、更新和删除使用相同的基本数据/行。

例如，您如何拥有一个表，如“artist_songs_counts”，列“song_id”（K）和“num_songs”（++），并确保“SongsService”为每个表添加相应的行；'songs' & 'songs_by_artist' & 'artist_songs_counts' （行数不同但信息应关联，例如艺术家信息）。

我需要帮助来实现使用 phantom 和 cassandra 的通知模型。到目前为止我所做的：

不知何故，我必须定义两个keyspaces，一个用于声明RootConnector，一个用于insert声明。这足够接近：这个例子，。然而，我的代码无法编译。我知道他们在那里使用了一个抽象类，因此它可以编译。

我的问题是我将如何使用那个抽象类？我只想从另一个 scala 源调用插入语句。

例如，我有一些

不知道会是什么内容。

但我认为 BlobColumn 可以很好地写入该数据。

但是我应该如何转换它以便 cassandra 保存并获取此记录？

我收到以下代码的以下错误。任何见解都非常感谢。不太清楚是什么原因造成的，因为我在整个应用程序中有大量其他用户定义的类型并没有导致这种行为。

让我知道是否需要更多信息才能提供指导/建议。

我正在使用幻像从我的 scala 代码连接到 cassandra 数据库。它以前工作过。但是今天在我升级到最新的 1.26.1 之后，它抛出了以下异常：

我正在使用 scala 2.11.7。奇怪的是降级到旧版本问题仍然存在。我知道它一定是别的东西。但我想不通。有什么帮助吗？

我正在尝试将两个具有相同数据的表链接起来，如下所示：http: //outworkers.com/blog/post/a-series-on-cassandra-part-1-getting-rid-of-the-sql-心理

我的第二个表包含我要查询的数据，例如：

所以这里我想通过时间戳或id查询。现在 a,b,c,d 是应该是唯一的项目，即 PRIMARY KEY(a, b, c, d)。为此，我创建了第一个表：

问题是，在插入期间，id 和 time 可能会改变，但 a、b、c、d 将保持不变。现在，我希望按照博文中提到的一致性做一些事情。我面临的问题是，如果我尝试插入一个相同的项目(a, b, c, d)， bar 会愉快地更新相应的行，但 foo 创建一个新条目。我将如何删除 foo 中的旧条目或更新 foo 之类的 bar ？？？

我正在为 scala 使用 phantom cassandra DSL。我想做的很简单：我想在每次有查询时查看并记录生成的查询。

我在 wiki或教程上找不到任何东西，也无法在网络上搜索。

有什么帮助吗？非常感谢。

在 cassandra 表中，我放置了类，其中一个字段是 AnyContent 类型。我将它序列化为字节数组。比我想从这个专栏中得到它到我的班级。我只能用方法得到fromRow(row: Row)它

只有这样才能编译

但它返回AnyContent(AnyContentAsJson({"body":"value"})并且很难解析并从中获取 JSON 值。

也许有一些直接的方法可以简单地得到它

当尝试一次将数千条记录插入远程 Cassandra 数据库时，我重复地遇到超时（在慢速连接上有 5 到 6 千个元素）

错误：

该模型：

连接器：

我尝试过单独和一起调整池选项。但即使将所有设置加倍REMOTE也没有明显改变超时

当前的解决方法，我想避免 - 将列表分成批次并等待每个批次完成：

处理这个问题的好方法是什么？

谢谢

编辑

这些错误确实表明集群出现故障/过载，但我怀疑网络在这里起主要作用。上面提供的数字来自远程机器。当同一个数据中心的机器提供相同的 C* 时，它们要高得多。另一个可疑的细节是，使用quill提供相同的 C* 实例不会遇到任何超时问题，无论是否远程。

我真正不喜欢节流的是批量大小是随机的和静态的，而它们应该是可适应的。