Описание тега phantom-dsl
Phantom DSL - это безопасный Scala DSL реактивного типа для Apache Cassandra и Datastax Enterprise. Это официальный драйвер Scala, созданный Websudos, который полностью поддерживает язык запросов CQL, предлагая мощный типобезопасный DSL для определения объектов Scala, которые реплицируют таблицы CQL.
1
ответ
Неявный TableHelper с 2.12.1?
Я что-то упустил полностью? Попытка построить абсолютно базовый проект с фантомом вызывает эту ошибку: could not find implicit value for parameter helper: com.outworkers.phantom.macros.TableHelper[models.Accounts,models.Account] build.sbt использует…
26 июн '17 в 20:22
1
ответ
Scala/Phantom ListColumn[Карта [Строка, Строка]]
У меня есть столбец базы данных с типом списка> в Cassandra, который я пытаюсь прочитать ListColumn[Map[String,String]] в моем CassandraTable учебный класс. Я получаю 2 ошибки компиляции: Error:(18, 25) could not find implicit value for evidence par…
23 дек '16 в 00:29
2
ответа
Как выбрать поля из SetColumn[String] в Phantom
У меня есть стол Кассандры Department с колоннами name_list extends SetColumn[String] with PartitionKey а также id extends StringColumn with PartitionKey, Я хочу получить идентификатор, где запрошенное имя присутствует в name_list. Я попытался испол…
06 сен '17 в 10:56
1
ответ
Что не так с CollectionColumn?
Я пытаюсь phantom от надомников, следящих за выложенным текстом на вики. Я использую тестовую модель: case class User (id: String, name: String, friends: List[String]) с: import com.websudos.phantom.dsl._ class Users extends CassandraTable[Users, Us…
10 янв '17 в 23:18
1
ответ
Получение WriteTimoutException для операций CAS
Я пытаюсь вставить довольно небольшое количество данных асинхронно, используя фантом для cassandra 3:9 однако этот запрос не выполняется:INSERT INTO test_db.test_tbl(name, last, ts) VALUES('aaa', 'bbb', 1502109409) IF NOT EXISTS USING TTL 0; Я получ…
07 авг '17 в 13:27
2
ответа
Призрак 1.25.4 с Кассандрой
Мне нужна помощь с реализацией модели уведомления с использованием фантома и кассандры. Что я сделал до сих пор: import java.util.UUID import com.websudos.phantom.dsl._ import com.websudos.phantom.connectors.Connector import org.joda.time.DateTime i…
18 май '16 в 11:15
1
ответ
Подключение к Cassandra при запуске и мониторинг состояния сеанса
Два связанных вопроса 1) В настоящее время сеанс на C* устанавливается лениво - иначе говоря, только при первом доступе к любой таблице.Вместо этого мы хотели бы установить сеанс сразу после запуска приложения (в случае проблем с подключением и т. Д…
16 янв '17 в 22:38
1
ответ
Как обновить поле, которое индексируется?
Я хочу обновить поле в Cassandra, которое индексируется с использованием Phantom Scala SDK, например: this.update.where(_.id eqs folderId) .and(_.owner eqs owner) .modify(_.parent setTo parentId) родительское поле является индексированным полем в та…
11 июн '15 в 09:58
1
ответ
ContactPoints против ContactPoint в Phantom-DSL
Почему у Phantom-DSL есть два разных способа использования ContactPoints и ContactPoint для коннекторов? При использовании ContactPoint я могу опустить использование host или host в качестве String, но здесь я должен указать порт. val default: Cassa…
13 сен '17 в 10:53
1
ответ
Запрос SetColumn
Как я могу искать НЕ СОДЕРЖИТ в наборе? Скажем, у меня есть следующая модель: case class ClassRoom(id:String, age:Int, name:String , kids: Set[String]) abstract class PersonModel extends CassandraTable[PersonModel, Person] { override def tableName =…
11 дек '16 в 15:19
1
ответ
Phantom dsl 2.24 таблицы не создаются
Недавно пытаюсь перейти на последнюю фантомную версию 2.24.8. Я создал фиктивный проект, но столкнулся с несколькими проблемами, которые я не могу понять. Вот мой код: import com.outworkers.phantom.connectors.{CassandraConnection, ContactPoints} imp…
25 июл '18 в 18:09
1
ответ
Неявный не найден в магазине
Я следовал шаблону из примеров на GitHub. Когда я вызываю store для объекта модели, передавая экземпляр объекта, я получаю ошибку компиляции, указывающую на отсутствие одного из неявных параметров, как показано ниже. could not find implicit value fo…
02 окт '17 в 17:16
0
ответов
Phantom: создание новой таблицы динамически
Я работаю над новым проектом, в котором мы используем драйвер Phantom для Cassandra. Таблицы определяются с использованием DSL Phantom. Теперь я хотел бы создавать новые таблицы динамически, это означает, что я не знаю, какие столбцы нужны заранее, …
28 ноя '18 в 16:16
1
ответ
Как получить данные для необязательного списка пользовательских типов данных в Кассандре, используя Websudos Phanthom
У меня есть таблица, в которой один столбец имеет тип Список параметров пользовательского объекта. Как получить данные из Кассандры для этого столбца, используя фантом Websudos. Схема таблицы: Сервер {имя_хоста: строковый порт: фильтр Int: опция [сп…
17 авг '15 в 11:00
1
ответ
Как мы можем выбрать запрос, используя фантомный драйвер без определения таблицы
У меня есть потоковая передача данных от SparkStreaming. Который мне нужно обработать и, наконец, хотите сохранить данные в Кассандре. Итак, ранее я пытался использовать разъем SparkCassandra. Но это не дает доступ к объекту SparkStreaming Context н…
15 сен '16 в 10:43
1
ответ
Phantom DSL Условное обновление
У меня есть следующее условное обновление, возвращающее false. Но когда я проверяю базу данных, столбцы, которые я пытался обновить, фактически обновляются. def deliver(d: Delivery, placedDate: java.time.LocalDate, locationKey: String, vendorId: Str…
07 ноя '17 в 20:48
1
ответ
Scala Phantom Cassandra Условная вставка?
Я использую библиотеку Phantom для вставки строк из моего кода Scala в Cassandra. Таким образом, в основном я создаю класс, который расширяет CassandraTable, а затем я получаю все методы создания и обновления из фантомной библиотеки. Одна вещь, кото…
25 мар '17 в 20:50
1
ответ
Phantom-Cassandra Вставка / обновление поведения
Я пытаюсь связать две таблицы с одинаковыми данными, как здесь: http://outworkers.com/blog/post/a-series-on-cassandra-part-1-getting-rid-of-the-sql-mentality Моя вторая таблица содержит данные, к которым я хочу запросить, например: foo ( id text, ti…
22 май '16 в 11:07
2
ответа
Фантомное сопоставление Java 8 LocalDateTime с Joda Time
Я использую Phantom 1.28 с Cassandra 3.7. У меня есть кейс-класс с Java 8 LocalDateTime: case class User( verifiedAt: Option[LocalDateTime] = None ) В фантомной модели: class UserModel extends CassandraTable[ConcreteUserModel, User]{ object verified…
01 сен '16 в 10:28
4
ответа
Отражение Java/Scala: Получить методы класса в порядке и вызвать инициацию объекта
У меня есть class с несколькими объектами в качестве внутренних методов. Я также задал этот вопрос некоторое время назад и получил хороший ответ, но это приводит к фатальным ошибкам в контейнерах сервлетов. Scala не может последовательно генерироват…
14 мар '14 в 13:03