phantom-dsl

    0热度

    1回答

    我想使用幻像来处理我的卡桑德拉 这是我的例子来学习怎么用幻影(感谢蒂亚戈) https://github.com/thiagoandrade6/cassandra-phantom 我可以成功运行'SongTest'。 但我在我的scala主对象中运行database.create有些麻烦。 'scalatest'中的相同代码已成功运行。但在我的Scala主要对象中,它失败了。 这是我的源代码 pa

    0热度

    1回答

    我想插入数据到我的Cassandra表中,然后从列“user_id”而不是完整的ResultSet返回值。这里是我的代码片段: def create(user: User): Future[UUID] = { insert .value(_.id, user.id) .value(_.email, user.email) .value(_.name,

    0热度

    1回答

    Phantom DSL中是否有方法指定每个分区缓存的行数?我可以这样做: .create.ifNotExists()。 with(缓存方程Cache.RowsOnly()) 但我不能找到办法如何指定比如缓存条件:所有键+每个分区500行。

    0热度

    1回答

    从 http://outworkers.com/blog/post/a-series-on-phantom-part-1-getting-started-with-phantom 我试图连接到具有这样的多个节点集群卡桑德拉摘自: object Defaults { val hosts = Seq("Cassnode1.company.com", "Cassnode2.company.c

    0热度

    1回答

    我试图从外包工phantom维基上的布局tut。 我使用的是测试模型: case class User (id: String, name: String, friends: List[String]) 有: import com.websudos.phantom.dsl._ class Users extends CassandraTable[Users, User] { ob

    1热度

    2回答

    以下指南here我尝试为嵌入式存储的Cassandra构建测试套件。但是,当我运行sbt test时出现以下错误: Error connecting to localhost/127.0.0.1:9142 (Connection refused: localhost/127.0.0.1:9142)。 因此,这里是我的代码(我把所有的拼在一起): case class User( id: S

    0热度

    1回答

    Cassandra完全新增。尝试使用phantom-dsl初始化Cassandra中的数据库。我收到了这个错误信息。 *** RUN ABORTED *** java.lang.AssertionError: assertion failed: no symbol could be loaded from class com.datastax.driver.core.Cluster in

    1热度

    1回答

    这是设置默认(读写)一致性水平 val connector: KeySpaceDef = ContactPoints(hosts, port).withClusterBuilder { builder => builder.withQueryOptions(new QueryOptions().setConsistencyLevel(ConsistencyLevel.QUORUM)) }.keyS

    0热度

    1回答

    我想定义一个新的列/转换器将一个案例类编组为一个基元类型,并使用幻影dsl再次回来。 在光滑3.1.1我可以很容易地做到这一点: implicit val idTypeMapper = MappedColumnType.base[Id, Long]( { (v) ⇒ v.value }, { (s) ⇒ Id(s) } ) 这让我在光滑的查询中使用Id的任何地方,它会隐式转

    1热度

    1回答

    当我们增加一个查询中每行更新的列数时,cassandra性能会增加还是下降。 说,我们有一个表组(例如FB组),这approches是最好的: 1 /表集团(的groupId诠释,名称的字符串,成员地图(用户ID - >角色)) 或 2 /表集团(的groupId诠释,名称的字符串,管理员设置[INT],主持人设置[INT],simpleMembers设置[INT]) 我们假设一个用户都可以有主持