问题标签 [phantom-dsl]

我一直在玩弄幻影wiki中提供的smiple代码，我试过了；

但是我的 IDE 一直在说Cannot resolve symbol where，编译器说value where is not a member of com.websudos.phantom.builder.query.RootSelectBlock[Students,Student]

我正在使用 Scala2.11.6和 Phantom 1.10.1，非常感谢所有帮助！

我是火花和卡桑德拉的新手。我正在尝试使用 spark-cassandra 连接器插入 cassandra 表，如下所示：

当我使用上述方法（包含 100 个实体的列表）插入时，它需要300-1100 milliseconds. 我尝试使用幻像库插入相同的数据。它只占用不到20-40 milliseconds.

谁能告诉我为什么火花连接器要花这么多时间来插入？我在我的代码中做错了什么还是不建议使用spark-cassandra 连接器进行插入操作？

我有一个表，其中一列是自定义对象的选项列表类型。如何使用 Websudos phantom 从 cassandra 获取本专栏的数据。

表架构：

服务器{主机名：字符串端口：整数过滤器：选项[列表[过滤器]]}

过滤器{过滤器键：字符串，值：列表（字符串）}

我为表“服务器”和“过滤器”创建了一个案例类。

这将提供List[filter]，如何进一步转换成Option[List[Filter]]

我有一个使用 phantom v1.5.0 的查询，它有多个 orderBy 子句，因为 orderBy 函数需要一个或多个OrderingConditions。

在 1.11.0（实际上是 1.8.0）的更新中，查询 API 更改为仅允许一种排序条件。当我尝试链接orderBya时，第一个返回的SelectQuery错误如下：SelectQueryorderBy

似乎 Ordered 不等于 Unordered 似乎很明显，但似乎也暗示您只能按一列总计排序。

如何orderBy在新的 Phantom 查询 API 中添加多个 s？

我是 scala 的新手（长期的 java 开发人员）。我试图理解隐含的，我想我理解了基础知识，但是我不明白为什么它找不到隐含的价值session。我试图用尽可能多的信息来描述我的问题。

我关注了以下博客文章：http ://blog.websudos.com/2015/04/04/a-series-on-phantom-part-1-getting-started-with-phantom/

在我想测试它之前，一切都很好/编译。收到以下错误：

当我执行以下测试类时：

我还复制了我在下面写的其他类：

TwitterMessages.scala

数据库.scala

我最近开始处理大量数据，这些数据也需要通过常规事务处理。

选择 Cassandra，我的数据模型使用动态列。我知道使用 CQL 可以更改表并插入或查询列以获取所需的数据。

但是，我在 Cassandra 中使用带有 Scala 的 Phantom 客户端并阅读了文档，但我找不到写入或查询动态列族的方法。

鉴于我们使用案例类，如何在 Scala 中使用 Cassandra 处理动态列？

phantom-dsl 中是否有批量插入 API 可以批量插入到 cassandra？尝试搜索但无法在代码中找到它。

我也找不到关于幻像库的足够文档。

我一直在开发一个需要同时进行定期写入和大量读取的应用程序。

该应用程序存储了一些大小不是很大的文本列，其中一个映射是表中最大的列。

在 Scala 中使用 Phantom-DSL（下面的 Datastax Java 驱动程序），当数据大小增加时，我的应用程序崩溃。

这是我的应用程序的日志。

这是cassandra 日志。

我已将 Cassandra 日志发布在 pastebin 中，因为它们非常大，无法嵌入答案中。

我似乎无法理解这次崩溃的原因。我尝试增加超时并关闭行缓存。

据我了解，这是一个基本问题，可以通过针对这种特殊情况调整 cassandra 来解决。

我的 cassandra 使用来自不同的数据源。所以写入不是很频繁。但是读取的大小很大，因为一次可能需要超过 300K 行，然后需要通过 HTTP 传输。

在 Websudos Phantom DSL 上，如何定义列名，但它已经是 Scala 的预定义变量，比如type？

例子：

如何定义type列，因为它已经是 Scala 的预定义变量？

目前使用——

使用 phantom-dsl 1.12.2 , Scala 2.10 ..

我不知道如何设置查询的一致性级别。

作为 .. 的一部分，insert()有预定义的函数。我怎样才能将一致性级别传递给它们？select()CassandraTable

不起作用并因错误而失败（可能是因为这在查询末尾附加了“USING CONSISTENCY QUORUM”）。这是我得到的实际异常

我从有关此拉取请求的文档和讨论中看到，我可以setConsistencyLevel(ConsistencyLevel.QUORUM)对 SimpleStatement 执行操作，但我不希望重写所有不同的插入语句。

更新

只是为了结束这个问题的循环。我通过创建一个自定义InsertQuery然后使用它而不是final def insertin提供的那个来解决这个问题CassandraTable