Stack Overflow
Stack Overflow

Questions tagged [phantom-dsl]

Phantom DSL is the reactive type safe Scala DSL For Apache Cassandra and Datastax Enterprise. It is the official Scala driver built by Websudos and it features full support for the CQL query language by offering a powerful type safe DSL to define Scala objects that replicate CQL tables.

Phantom DSL is the reactive type safe Scala DSL For Apache Cassandra and Datastax Enterprise. It is the official Scala driver built by Outworkers and it features full support for the CQL query language by offering a powerful type safe DSL to define Scala objects that replicate CQL tables.

Phantom will prevent invalid queries at compile time and help you automate concerns like testing, connecting to Cassandra, and automating a lot of the operations pipeline.

150 questions
13
votes
5 answers

cassandra with scala

Does anyone have advice on using cassandra with scala? There is no native scala-cassandra client supporting cassandra version 8.0+, so I have to use hector, and it seems to work OK but not to be concise. Do you have any attempts, recommendations or…
sirmak
  • 3,749
  • 4
  • 30
  • 34
8
votes
4 answers

Java/Scala reflection: Get class methods in order and force object init

I have a class with a few objects as inner methods. I also asked this question a while ago and got a good answer, but that leads to fatal errors in servlet containers. Scala cannot consistently generate a TypeTag when the URLClassLoader asks for a…
flavian
  • 28,161
  • 11
  • 65
  • 105
7
votes
2 answers

play 2.3.8 sbt excluding logback

I'm having a really hard time excluding logback from my play 2.3.8 test run. I've tried many exclude rules, but nothing seems to work. I also can't find it in my dependency tree. Snippet from my sbt file: [...] resolvers ++= Seq( "Typesafe…
Foo L
  • 10,977
  • 8
  • 40
  • 52
7
votes
1 answer

How does Phantom DSL for Cassandra actually connect?

I'd like to use the Phantom DSL for Cassandra from Scala. I've noted that it uses the Datastax Java driver underneath, but I don't see anything in the documentation about how to actually connect or configure a connection. The included tests use an…
Isvara
  • 3,403
  • 1
  • 28
  • 42
6
votes
1 answer

How to work with and query dynamic column families in Phantom for Cassandra?

I have recently started working with heavy and massive data which also needs to go through regular transaction. Choosing Cassandra, my data model uses dynamic columns. I understand that with CQL one can alter tables and insert or query columns to…
chbh
  • 336
  • 2
  • 13
5
votes
1 answer

How to effectively read millions of rows from Cassandra?

I have a hard task to read from a Cassandra table millions of rows. Actually this table contains like 40~50 millions of rows. The data is actually internal URLs for our system and we need to fire all of them. To fire it, we are using Akka Streams…
Thiago Pereira
  • 1,724
  • 1
  • 17
  • 31
5
votes
1 answer

How to specify columns programmatically within query clauses using phantom-dsl for cassandra

I need to create dynamic query clauses depending on user input, i.e. dynamically specifying the column within a query. All the examples are of the form .where(_.id eqs myUuid) however I need sth along the lines of .where('id' eqs myUuid) which is…
sinel
  • 51
  • 3
5
votes
2 answers

value slice is not a member of play.api.libs.iteratee.Enumerator

I am writing code based on "Asynchronous iterators for large record sets" described at https://github.com/websudos/phantom#partial-select-queries import scala.concurrent.ExecutionContext.Implicits.global import scala.concurrent.Future import…
Rahul Singhai
  • 1,299
  • 15
  • 27
5
votes
2 answers

phantom-dsl_2.11 error implicit session

I'm trying to connect to the cassandra database (With scala 2.11.2) using the phantom scala driver I followed this article on their blog: http://blog.websudos.com/2014/08/a-series-on-cassandra-part-1-getting-rid-of-the-sql-mentality/ (note on github…
Guillaume
  • 694
  • 1
  • 6
  • 15
4
votes
0 answers

How does one use phantom-dsl to connect DataStax Astra?

How does one use phantom-dsl to connect DataStax Astra? Enhancement request #920 was created, but no movement on that. I am finding it too hard to find any information on how to leverage SSL alongside this driver. Any help is appreciated!
Madhavan
  • 758
  • 4
  • 8
4
votes
1 answer

outworkers phantom disable table create for some but not all tables in a cassandra keyspace

I am working on the "write" side of a cassandra database using the outworkers phantom scala library. The "read" side is in a different micro-service that is responsible for creating the keyspace and shared tables. The "write" side however does…
jmcnulty
  • 190
  • 10
4
votes
2 answers

Cassandra insert performance using spark-cassandra connector

I am a newbie to spark and cassandra. I am trying to insert into cassandra table using spark-cassandra connector as below: import java.util.UUID import org.apache.spark.{SparkContext, SparkConf} import org.joda.time.DateTime import…
Yadu Krishnan
  • 3,492
  • 5
  • 41
  • 80
3
votes
1 answer

How to build a Phantom CassandraConnection from datastax ClusterBuilder

I have the following code written on the datastax driver to establish a cassandra connection. val cluster = Cluster.builder() .withCompression(ProtocolOptions.Compression.LZ4) .addContactPoints(List("a", "b").asJava) …
Knows Not Much
  • 30,395
  • 60
  • 197
  • 373
3
votes
1 answer

Using Phantom 2 with an existing Cassandra session

I am trying to migrate our current implementation from Phantom 1.28.16 to 2.16.4 but I'm running into problems with the setup. Our framework is providing us with the Cassandra session object during startup which doesn't seem to fit with Phantom. I…
Johan J
  • 101
  • 2
  • 4
3
votes
1 answer

How to fetch data from ListColumn[String] in Phantom using contains condition

I have a Cassandra table Department with columns name_list extends ListColumn[String] and id extends StringColumn with PartitionKey. I want to fetch id where the requested name is present in name_list. I tried using in operator…
Charmy Garg
  • 291
  • 2
  • 14
1
2 3
…
9 10