phantom-dsl

    2热度

    1回答

    当试图几千条记录一次插入到远程卡桑德拉分贝,我重复地遇到超时(5〜6千的元素连接速度慢) 错误: All host(s) tried for query failed (tried: /...:9042 (com.datastax.driver.core.exceptions.OperationTimedOutException: [/...] Timed out waiting for se

    0热度

    1回答

    我有一个表 CREATE TABLE userssbyprofit ( userid text, profit double, dateupdated timeuuid, PRIMARY KEY (userid, profit, dateupdated) ) WITH CLUSTERING ORDER BY (profit DESC, dateupdated

    0热度

    1回答

    我有阿卡-HTTP 2.4.2和com.websudos.phantom1.22.0 所有工作正常,但我不一个新项目,改变阿卡-HTTP日志级别知道如何将日志级别更改为INFO像幽灵如此的调试日志: 17:00:51.792 [cluster1中,NIO工人-0] DEBUG com.datastax.driver.core.Connection - 连接[/192.168.120.24:9042

    5热度

    1回答

    我需要根据用户输入创建动态查询子句,即动态指定查询中的列。所有的例子都是形式的 。哪里(_。ID公式myUuid) 不过,我需要沿着 。凡行( '身份证' 方程myUuid)某 这不可能。有什么办法可以使用phantom-dsl动态指定查询列吗?

    0热度

    1回答

    我正在构建一个简单的Scala Play应用程序,该应用程序使用Scala的Phantom DSL驱动程序将数据存储在Cassandra DB中。 Cassandra的一个很好的功能是可以进行部分更新,即只要您提供了关键列,您就不必为表中的所有其他列提供值。 Cassandra会根据密钥将数据合并到您现有的记录中。 不幸的是,这似乎不适用于Phantom DSL。我有一个包含多列的表,我希望能够进

    0热度

    1回答

    已遵循需要json序列化程序的集合column tutorial for phantom-dsl。 下面的实现获取以下错误输出; 发现:org.dyne.danielsan.superchain.data.models.JsonVin [错误]需要:org.json4s.JValue [误差(其扩展到)org.json4s .JsonAST.JValue [错误]紧凑的(渲染(OBJ)) 在指出我

    1热度

    2回答

    在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/outworke

    0热度

    1回答

    这是一个扩展到这样一个问题: How to increment Cassandra Counter Column with phantom-dsl? 这个问题也被要求here。 在Thiagos example这两个表; “歌曲” &“songs_by_artist”都具有相同的行,但用不同的分区(主键/集群列) CREATE TABLE test.songs ( song_id time

    0热度

    2回答

    我需要使用幻像和卡桑德拉实现通知模型的帮助。我已经做了到现在什么: import java.util.UUID import com.websudos.phantom.dsl._ import com.websudos.phantom.connectors.Connector import org.joda.time.DateTime import scala.concurrent.F

    0热度

    1回答

    在卡桑德拉表中,我把类,其中一个字段是AnyContent类型。我将它序列化为字节数组。比我想从这个专栏到我的班级。我可以在方法得到它fromRow(row: Row)只喜欢 AnyContentAsText(TypeCodec.varchar().deserialize(body(row), ProtocolVersion.NEWEST_SUPPORTED)) 只有这样的方式将其编译 但它