Я новичок в Spark и Cassandra. Я пытаюсь вставить в таблицу cassandra, используя разъем Spark-Cassandra, как показано ниже: import java.util.UUID import org.apache.spark.{SparkContext, SparkConf} import org.joda.time.DateTime import...

Я работаю над приложением, которое требует одновременной регулярной записи и массивного чтения. Приложение хранит несколько текстовых столбцов небольшого размера и карту, которая является самым большим столбцом в таблице. Работая с Phantom-DSL в...

У меня есть класс case с несколькими вложенными классами. Как мне моделировать с помощью Phantom DSL Поместить все это в один класс case — не вариант. Например: case class Car(age: Int,size: Int,door: Door) case class Door(color:String,...

Я использую фантомный cassandra DSL для scala. То, что я хочу сделать, просто: я хочу видеть и регистрировать сгенерированные запросы каждый раз, когда есть запрос. Я ничего не могу найти на вики или в руководствах и поиске в Интернете. Любая...

В настоящее время я рассматриваю возможность использования Cassandra в качестве моей базы данных в проекте PlayFramework. Я искал реактивный драйвер, и, кажется, мой выбор ограничен Phantom и Quill. Мой опыт работы с базами данных nosql ограничен...

Этот вопрос связан с предыдущим вопросом . Но так как этот вопрос закрыт, я должен создать отдельный. Вариант использования таков: у меня есть таблица с 5 столбцами. При создании записи требуется всего 2 столбца. Позже пользователи будут...

Я новичок в cassandra (несколько дней назад начал учиться в своем собственном интересе) и ищу помощи по следующей проблеме. У меня есть таблица Cassandra «Пользователь» и ListColumn «интересы расширяют ListColumn [String]». Теперь я хочу привлечь...

В настоящее время я работаю над интеграцией Phantom DSL в небольшое приложение Play. Поскольку мы планируем запустить приложение в среде Docker, я использую Docker Compose на своем локальном компьютере для тестирования приложения. Однако при...

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

При вставке/обновлении в Cassandra или, скажем, определение таблицы в приложении не соответствует определению таблицы на сервере C*, как фантом обрабатывает эти типы ошибок? Я вижу результирующий набор, который wasApplied и т. д., но ничего об...

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

Я использую Phantom DSL ( v2.28.0, scala v2.12.7 ), и при каждом запросе к моей базе данных я получаю следующую неоднозначную ошибку: scala.NotImplementedError: отсутствует реализация Этого не происходит, когда я использую .future() для...

Я работаю с Cassandra 3.x и драйвером Phantom (scala) и изменяю развертывание Cassandra с простого кластера из трех узлов на развертывание Cassandra с несколькими центрами обработки данных, состоящее из двух центров обработки данных: Транзакционный...