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

Не удается создать стресс-клиент базы данных cassandra с помощью DataStax
Я работаю со своим собственным кластером базы данных с cassandra. Я хочу попробовать несколько стресс-тестов с моей базой данных, поэтому я скачал Java-драйвер DataStax для Cassandra. https://github.com/datastax/java-driver После того, как я...
597 просмотров

Как использовать функцию асинхронной / пакетной записи с драйвером Datastax Java
Я планирую использовать драйвер Datastax Java для записи в Cassandra. Меня в основном интересовали функции Batch Writes и Asycnhronous драйвера Java Datastax, но я не могу получить никаких руководств, которые могли бы объяснить мне, как включить...
11741 просмотров
schedule 06.07.2022

`InvalidQueryException: невозможно проанализировать '[B@50908fa9' как шестнадцатеричные байты` с помощью драйвера Datastax Java
Я пытаюсь вставить массив байтов в тип данных Blob в моей таблице Cassandra. Я использую драйвер Datastax Java. Ниже мой код - for (Map.Entry<String, byte[]> entry : attributes.entrySet()) { System.out.println("Key = " + entry.getKey()...
819 просмотров
schedule 20.06.2023

org.jboss.netty.channel.ChannelPipelineException: не удалось инициализировать конвейер
У меня есть приложение, которое подключается к Cassandra с помощью драйвера Java, извлекает некоторую конфигурацию и на основе результатов генерирует и выполняет некоторые сценарии PIG. Теперь я могу успешно подключиться к Cassandra, когда...
853 просмотров

Драйвер Cassandra Datastax - пул подключений
Я пытаюсь понять пул соединений в Datastax Cassandra Driver, чтобы лучше использовать его в своем веб-сервисе. У меня версия 1.0 документации. Он говорит: Драйвер Java использует соединения асинхронно, поэтому несколько запросов могут быть...
13088 просмотров
schedule 25.12.2022

Cassandra: вставка ошибки timeuuid
У меня есть следующая таблица create table test( userId varchar, notifId timeuuid, notification varchar, time bigint,read boolean, primary key(userId, notifId)) with clustering order by (notifId desc);...
8331 просмотров
schedule 04.08.2023

NoHostAvailableException с 1000 одновременных запросов к Cassandra с драйвером DataStax Java
Настройка: -кластер Cassandra 2.0.7.31 с 2 узлами -replicas=1 -с конфигурацией по умолчанию -с использованием драйвера Java DataStax 1.0 Действие Простой запрос на вставку с использованием класса QueyBuilder Результат...
1297 просмотров
schedule 30.05.2023

Исключение в основном потоке java.lang.NoClassDefFoundError
Получение исключения ошибки в потоке "main" java.lang.NoClassDefFoundError: com / google / common / util / concurrent / FutureCallback при выполнении кода ниже. Пожалуйста, сообщите, какой файл Jar отсутствует. Я выполняю из Eclipse IDE package...
7348 просмотров

InvalidQueryException, несмотря на наличие вторичного индекса?
У меня есть семейство столбцов, описанное ниже. У меня есть вторичный ключ для столбца имени. CREATE TABLE group ( pid timeuuid, members map<bigint, boolean>, name text, PRIMARY KEY ((pid)) ) WITH...
590 просмотров

Храните простые пары ключ-значение в Cassandra 2+
в настоящее время мы используем HBase для хранения наших данных. Поэтому мы создали абстрактный класс, который содержит карту, и эта карта затем сохраняется через Java API. примерный класс будет class User extends AHBase { public static String...
845 просмотров
schedule 03.02.2023

Кластер Cassandra с плохой производительностью вставки и стабильностью вставки
Мне приходится хранить около 250 числовых значений в секунду для каждого клиента, что составляет около 900 тыс. чисел в час. Вероятно, это не будет запись в течение всего дня (вероятно, от 5 до 10 часов в день), но я разделю свои данные на основе...
5058 просмотров

Обновление Cassandra тихо завершается с ошибкой на нескольких узлах
У меня следующая ситуация. Есть таблица CQL (Cassandra 2.0.12) CREATE TABLE article ( version timeuuid, id timeuuid, active boolean, contentbody text, contentformat text, createdat text, entitytype text, externalsources...
1651 просмотров
schedule 21.04.2023

Предотвратить ведение журнала stacktrace для плохой точки контакта Cassandra
Когда моей клиентской программе Cassandra, которая использует драйвер Datastax Java, дается недопустимая точка контакта (имя хоста компьютера, на котором фактически не запущен демон Cassandra), драйвер сам регистрирует трассировку стека. Однако...
704 просмотров
schedule 14.07.2022

Все мастера не отвечают! ? Мастер Spark не отвечает архитектуре datastax
Пробовали использовать как оболочку Spark, так и отправку Spark, получая это исключение? Initializing SparkContext with MASTER: spark://1.2.3.4:7077 ERROR 2015-06-11 14:08:29 org.apache.spark.scheduler.cluster.SparkDeploySchedulerBackend:...
3359 просмотров

Сопоставление столбца типа списка/набора/карты с помощью средства сопоставления объектов datastax
Я пытаюсь использовать картограф datastax, и он отлично работает для всех примитивных типов. У меня возникли проблемы с использованием его для столбца типа карты в таблице cassandra. Возможно, проблема также связана с типом столбца Set и List....
1485 просмотров
schedule 04.07.2023

Тайм-аут Cassandra во время запроса чтения при согласованности ОДИН (требуется 1 ответ, но ответила только 0 реплика)
Я выполняю запросы на чтение и обновление в таблице, содержащей 500000 строк, и иногда получаю ошибку ниже после обработки около 300000 строк, даже если ни один узел не отключен. Тайм-аут Cassandra во время запроса на чтение при...
22091 просмотров

Все хосты, которые пытались выполнить запрос, завершились неудачно - com.datastax.driver.core.OperationTimedOutException
При выполнении операций Cassandra (пакетное выполнение - операции вставки и обновления в двух таблицах) с использованием искрового задания я получаю сообщение « Все хосты, пытающиеся выполнить запрос, завершились неудачно - com. Datastax. Driver....
5793 просмотров

Сбои запроса Cassandra: все хосты, которые пытались выполнить запрос, не прошли (ни один хост не был опробован)
Я не могу выполнять запросы к узлу Cassandra. Я могу подключиться к кластеру и подключиться. Однако при выполнении запроса он не работает Caused by: com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed...
6173 просмотров

Кассандра игнорирует FetchSize
У меня есть таблица Cassandra с 1000 строк. Я использую java-драйвер datastax 2.1.8 с Cassandra 2.1.3. Я установил fetchSize равным 10 для подготовленного оператора выбора. Код на Скале: val stmt = preparedStatement.bind()...
434 просмотров

Как удалить все записи из таблицы cassandra без создания снимка
Столкнулся с проблемой удаления всех записей из таблицы. Я могу использовать таблицу Truncate. Но усечение создаст моментальный снимок данных, что в моем сценарии будет пустой тратой места для хранения. Также усечение завершится ошибкой, если...
3070 просмотров