Описание тега phantom-dsl

Описание тега Вопросы с тегом
Phantom DSL - это безопасный Scala DSL реактивного типа для Apache Cassandra и Datastax Enterprise. Это официальный драйвер Scala, созданный Websudos, который полностью поддерживает язык запросов CQL, предлагая мощный типобезопасный DSL для определения объектов Scala, которые реплицируют таблицы CQL.
1 ответ

Phantom DSL моделирование кейсов

Я знаю, что у scala и / или JVM есть ограничение еще на 22 поля для классов дел, и лучший способ - разделить их на несколько классов дел, например: case class User(id: Long, username: String, password: String, address: Address) case class Address(id…
20 июн '15 в 19:32
1 ответ

Выполнение загрузки чтения на Кассандре с получением BusyPoolException

Я пытаюсь выполнить большое количество запросов с использованием Phantom версии 2.14.1, например: case class Foo(id: String, x: Long, y: Long) val list: List[Foo] = _ list.size = 100000 def find(id: String, x: Long, y:Long ) select .where(_.id eqs i…
21 авг '17 в 19:29
2 ответа

Производительность вставки Cassandra с использованием коннектора spark-cassandra

Я новичок в искре и Кассандре. Я пытаюсь вставить в таблицу cassandra, используя разъем свечи-кассандры, как показано ниже: import java.util.UUID import org.apache.spark.{SparkContext, SparkConf} import org.joda.time.DateTime import com.datastax.spa…
11 авг '15 в 12:16
1 ответ

Как фантомно обрабатывать ошибки

При вставке / обновлении в Cassandra или когда, скажем, определение таблицы в приложении не соответствует определению таблицы на сервере C*, как фантом обрабатывает эти типы ошибок? Я вижу набор результатов, который был wasApplied и т. Д., Но ничего…
07 ноя '16 в 21:40
2 ответа

Зависимость от фантома кассандры

У меня есть следующие bulid.sbt scalaVersion := "2.11.8" libraryDependencies += "com.websudos" %% "diesel-engine" % "0.3.0" libraryDependencies += "com.websudos" %% "phantom-dsl" % "1.27.0" когда sbt попробуйте разрешить зависимость после показа соо…
11 июл '16 в 16:21
2 ответа

Не удается подключиться к встроенному экземпляру Cassandra с помощью Phantom

Следуя этому руководству, я пытаюсь создать набор тестов для Cassandra со встроенным хранилищем. Однако когда я бегу sbt test Я получаю следующую ошибку: Error connecting to localhost/127.0.0.1:9142 (Connection refused: localhost/127.0.0.1:9142), Ит…
22 ноя '16 в 06:49
0 ответов

Ошибка зависимости Phanom - разъем свечи зажигания

Я получаю следующую ошибку при выполнении: Exception in thread "main" java.lang.IncompatibleClassChangeError: Class com.datastax.driver.core.DefaultResultSetFuture does not implement the requested interface com.google.common.util.concurrent.Listenab…
09 май '17 в 15:44
2 ответа

Создание таблицы в Cassandra с использованием Phantom в Scala

Я слежу за учебником здесь: http://blog.websudos.com/2015/04/04/a-series-on-phantom-part-1-getting-started-with-phantom/ Кассандра версия: 2.1.8 PhatomVersion 1.10.1 Версия Scala: 2.11.2 sbt-версия: 0.13.8 Помимо приведенного в статье кода у меня ес…
26 июл '15 в 11:43
1 ответ

Метод вставки Scala Phantom Cassandra возвращает пустой ResultSet

Я хочу вставить данные в мою таблицу в Cassandra, а затем вернуть значение из столбца "user_id" вместо полного ResultSet. Вот фрагмент моего кода: def create(user: User): Future[UUID] = { insert .value(_.id, user.id) .value(_.email, user.email) .val…
02 апр '17 в 17:04
1 ответ

Работа с NoHostAvailableException с фантомным DSL

При попытке вставить несколько тысяч записей одновременно в удаленную базу данных Cassandra, я воспроизводимо сталкиваюсь с таймаутами (с 5-6 тысячами элементов на медленном соединении) ошибка: All host(s) tried for query failed (tried: /...:9042 (c…
09 июн '16 в 16:03
0 ответов

Phantom DSL - чтение с последующей записью

Мне нужно обновить столбец, только если текущее значение удовлетворяет предварительному условию. Я попробовал ниже, def acceptDelivery(implicit sc: SecurityContext, ar: AcceptRequest) : Future[DeliveryResponse] = { for { d <- Database.DeliveryFor…
30 сен '17 в 17:57
2 ответа

Где в выборе с помощью Phantom не решает

Я играл с кодом smiple, представленным в фантомной вики, я попробовал следующее; import com.websudos.phantom.dsl._ case class Student(id: UUID, name: String) class Students extends CassandraTable[Students, Student] { object id extends UUIDColumn(thi…
11 авг '15 в 09:02
1 ответ

Производительность Cassandra: обновление столбцов по строкам

Увеличивается или уменьшается производительность кассандры, когда мы увеличиваем количество столбцов, которые должны обновляться в строке в одном запросе. Сказать, что у нас есть таблица групп (например, группы FB), которая подходит лучше всего: 1 /…
30 янв '17 в 11:33
2 ответа

cassandraunit немедленно падает

Я пытаюсь запустить модульные тесты cassandra на маленькой ванильной машине с Ubuntu 12, но тест или репл завершаются сразу же, не давая мне никакой информации. Когда я пытаюсь сделать это в ответ, я получаю следующее: scala> org.cassandraunit.ut…
08 дек '14 в 00:39
0 ответов

Обновление до Phantom cassandra 1.26 дает ошибку класса GenTraversableOnce$

Я использовал фантом для подключения к базе данных Кассандры из моего кода Scala. Это работало раньше. Но сегодня, после того как я обновился до последней версии 1.26.1, он выдает следующее исключение: Exception in thread "main" java.lang.NoClassDef…
21 май '16 в 13:44
1 ответ

Увеличьте и получите значение счетчика

Есть ли способ увеличить счетчик, а затем вернуть значение в один вызов? Или это единственный способ сделать 2 звонка?
20 окт '16 в 20:44
2 ответа

Как увеличить счетчик колонок Cassandra с помощью phantom-dsl?

Есть ли примеры реализации операции counter в 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…
15 май '16 в 08:35
1 ответ

Как создать фантомное соединение Cassandra из d asastax ClusterBuilder

У меня есть следующий код, написанный на драйвере datastax для установления соединения cassandra. val cluster = Cluster.builder() .withCompression(ProtocolOptions.Compression.LZ4) .addContactPoints(List("a", "b").asJava) .withCredentials("foo", "bar…
03 фев '18 в 19:07
1 ответ

Настройка времени соединения Cassandra в Phantom DSL

Я использую фантом для подключения к Apache Cassandra и хочу настроить соединитель во время выполнения, то есть я хочу проанализировать некоторый файл конфигурации, извлечь список баз данных Cassandra и передать его каким-то образом Database объект.…
27 фев '18 в 12:08
1 ответ

Websudo Phantom JDK8 не может видеть тип JdkLocalDateTime

Я использую phantom-dsl_2.11 версия 1.28.13. phantom-jdk8_2.11 версия 1.28.13. У меня все просто: User.scala Case User ( verifiedAt: Option[LocalDateTime] ) UserDatabase.scala import com.websudos.phantom.dsl._ import com.websudos.phantom.jdk8.dsl._ …
12 дек '16 в 08:25