Вопросы по теме 'datastax-java-driver'

Оптимальные настройки для драйвера Cassandra Java для записи только в локальный центр обработки данных
Я недавно начал использовать драйвер Datastax Java для нашего варианта использования Cassandra ... Мы будем использовать драйвер Datastax Java для чтения / записи в Cassandra ... Я успешно могу создать соединение Cassandra с помощью драйвера...
5452 просмотров
schedule 31.10.2021

Кассандра: игнорировать часовой пояс для значения отметки времени
Я написал программу, которая читает файл, содержащий дату (в формате yyyy / MM / dd), и использует драйвер Java Datastax для чтения даты и добавления ее в таблицу cassandra. Так, например, если моя запись содержит значение даты «2010/06/01», то это...
986 просмотров

Операция удаления Cassandra иногда не работает, можно выбрать данные после удаления
У меня есть две таблицы CREATE TABLE IF NOT EXISTS QueueBucket ( queueName text, bucketId int, scheduledMinute timestamp, scheduledTime timestamp, messageId uuid, PRIMARY KEY ((queueName, bucketId, scheduledMinute),...
1407 просмотров

Класс сопоставления объектов для нескольких пространств ключей в Cassandra DB
Я использую datastax-java-driver для cassandra, чтобы использовать Object Mapper для доступа к данным в таблице, как объяснено здесь . У меня проблема в том, что я хочу, чтобы этот сопоставленный класс работал в двух разных пространствах клавиш...
479 просмотров

Как преобразовать коллекции Java в Scala в драйвере Cassandra Datastax
Схема моей Cassandra таблицы id uuid PRIMARY KEY, description text, messages list<text>, image list<blob>, primary text, tags set<text>, title text, more text Я могу получить ResultSet из таблицы, но не знаю, как...
214 просмотров
schedule 19.09.2021

Как создать пул соединений Cassandra с помощью драйвера datastax
Я использую драйвер cassandra datastax v3.7.2 с java8. В документации упоминается «Вам не нужно самостоятельно управлять подключениями. Вы просто взаимодействуете с объектом сеанса, который обо всем позаботится». Если вы хотите создать пул...
653 просмотров

Несколько подготовленных операторов Cassandra для столбцов, допускающих значение NULL
Из-за ограничений инфраструктуры мы не можем обновить версию Cassandra до> 2.2, поэтому мы должны использовать 2.0.7. К сожалению, эта версия не поддерживает использование UNSET . Поскольку данные, которые мы пишем, имеют столбцы, допускающие...
313 просмотров

Cassandra NoHostAvailableException: все хосты, которые пытались выполнить запрос, завершились неудачно
Мы запускаем микросервис Java, который использует многоузловой кластер Cassandra DB. При записи данных случайным образом с разных узлов появляется следующая ошибка: com.datastax.driver.core.exceptions.NoHostAvailableException: все хосты, которые...
300 просмотров

Установка уровня согласованности с помощью драйвера Java для Apache Cassandra
Я пытаюсь проверить уровень согласованности настроек с помощью драйвера java. Я создал тестовое пространство ключей и таблицу с коэффициентом репликации = 3 (для целей тестирования настроен кластер узла 1). Я сделал вставку из драйвера java,...
1182 просмотров
schedule 11.03.2022

Почему запрос cassandra count использует разрешающую фильтрацию при выполнении без упоминания этого в моем коде?
Я использую spark-sql-2.4.1, spark-cassandra-connector_2.11-2.4.1 с java8. Я делаю простой запрос, как показано ниже, чтобы получить количество строк таблицы C *. JavaSparkContext sc = new JavaSparkContext(spark.sparkContext()); long recCount =...
249 просмотров

Datastax 4.6 Драйвер Java Object mapper async / batch query
Драйвер Datastax java версии 4.6, я не вижу поддержки в сопоставлении объектов для пакетных / асинхронных запросов Есть ли способ обхода этого? Любая причина, по которой objectmapper не поддерживает пакетную / асинхронную обработку? В предыдущей...
115 просмотров
schedule 23.03.2022

Невозможно подключиться к одному из узлов Cassandra с помощью драйвера Cassandra Datastax Java
Драйвер Cassandra datastax не может подключиться к одному из узлов в центре обработки данных, но я все еще могу читать и писать в базу данных. Датацентр содержит два узла в одной стойке. Я указал один из них как начальный узел. Connected to...
1116 просмотров

Использование уровня согласованности LOCAL_QUORUM в драйвере Datastax
По некоторым причинам мне нужно запросить конкретный центр обработки данных в моем кластере cassandra. Согласно документации , я могу использовать уровень согласованности LOCAL_QUORUM : Возвращает запись после кворума реплик в текущем центре...
1580 просмотров

Cassandra NoHostAvailableException, когда удаление выполняется с помощью cqlsh
У нас есть кластер с 7 узлами, и мы используем Java-драйвер datastax для подключения к кластеру. Проблема в том, что я получаю постоянное исключение NoHostAvailableException следующим образом: Вызвано:...
1039 просмотров
schedule 22.04.2022

Драйвер Datastax java 3.0.0 Перечислимые аннотации не найдены
Надеюсь, я хорошо читаю документы: http://docs.datastax.com/en/developer/java-driver/3.0/java-driver/reference/crudOperations.html . Пронумерованная аннотация Если ваш класс содержит поле типа перечисления, вы используете аннотацию Enumerated....
1474 просмотров

Как дросселировать запрос записи в кассандру при работе с executeAsync?
Я использую драйвер Java Datastax 3.1.0 для подключения к кластеру cassandra, а моя версия кластера cassandra - 2.0.10. Я пишу асинхронно с КВОРУМНОЙ последовательностью. private final ExecutorService executorService =...
2881 просмотров

подключение драйвера datastax = apache ignite и cassandra (вы можете увеличить количество подключений драйвера на хост)
Компоненты: apache ignite + apache cassandra. Используйте драйвер datastax по умолчанию. После выполнения нескольких операций (около 3-5 миллиардов сущностей помещается в кеш) мы получаем ситуацию, когда драйвер datastax всегда переподключается к...
264 просмотров

Асинхронное выполнение с помощью datastax mapper
Можем ли мы выполнять пакетные операторы с Datastax mapper для Cassandra (драйвер Java)? Я хочу выполнить пакетный оператор асинхронно, не блокируя результат. Есть какие-нибудь примеры?
785 просмотров
schedule 14.06.2022

Datastax cassandra, кажется, кеширует preparestatent
Когда мое приложение работает долго, все также работает. Но когда я меняю тип столбца с int на текст (удалить таблицу и воссоздать), я поймал исключение: com.datastax.oss.driver.api.core.type.codec.CodecNotFoundException: Codec not found for...
170 просмотров
schedule 25.06.2022

Поведение пользовательского типа (UDT) в Cassandra
если у кого-то есть опыт использования UDT (пользовательские типы), я хотел бы понять, как будет работать обратная совместимость. Скажем, у меня есть следующий UDT CREATE TYPE addr ( street1 text, zip text, state text ); Если я...
662 просмотров