Описание тега datastax-java-driver
Клиентский драйвер Java для Apache Cassandra. Этот драйвер работает исключительно с языком запросов Cassandra Query Language версии 3 (CQL3) и двоичным протоколом Cassandra.
1
ответ
Как получить точный CQL из оператора, используя Java API из Datastax
Мой код непосредственно выполняет связанный оператор, подготовленный без какого-либо точного запроса. Тогда как получить cql, который он пытается выполнить в базе данных cassandra? Например: public <T> void save(T entity) { if (entity != null)…
02 мар '16 в 09:54
1
ответ
Столбец метки времени запроса Кассандры
Использование Cassandra 2.28, Drive 3, Sparks2. У меня есть столбец меток времени в Кассандре, мненужно запросить его только по части даты. Если я сделаю запрос по дате: .where("TRAN_DATE= ?", "2012-01-21": это не приносит никакого результата. Если …
15 дек '16 в 03:00
0
ответов
Проблемы со стуком в EC2
Я впервые попытался развернуть приложение в EC2. У меня было три экземпляра кассандры в одном регионе со стукачом EC2. Я использовал драйвер Java datastax для подключения приложений. На уровне ключей я настроил стратегию сетевой топологии. Когда я п…
07 ноя '14 в 11:15
1
ответ
Запись фрагментированных данных с помощью драйвера Datastax Java
При использовании Astyanax в качестве клиентской библиотеки для Cassandra есть функция Chunked Object Store для хранения больших файлов. Я не могу найти какую-либо документацию или примеры, связанные с драйвером Datastax, которые показывают, что я м…
02 июл '15 в 09:01
1
ответ
Ограничение размера очереди асинхронных запросов
Я использую Cassandra Java Driver 2.0 в асинхронном режиме. Когда я выполняю много операций очень интенсивно, они должны быть помещены в очередь где-то внутри драйвера, прежде чем они будут отправлены в сеть. Я хотел бы установить предел размера оче…
01 авг '14 в 17:08
0
ответов
DataStax Enterprise: Spark задание не регистрирует пользовательские сообщения
Я использую искру, которая является частью DSE 5.0.11. Невозможно записать сообщение из моей работы потоковой передачи Spark. Вот содержимое файла log4j.properties: log4j.rootLogger=DEBUG, file log4j.appender.file=org.apache.log4j.RollingFileAppende…
02 фев '18 в 11:30
0
ответов
Jmeter - Драйвер Datastax cassandra сохраняет вывод журнал пульса DEBUG
Я использую конфигурацию соединения JDBC для подключения к кластеру Cassandra. Когда мой тест завершен, в моем терминале все еще продолжается вывод журнала пульса: 18: 05: 02.306 [cluster1-nio-worker-4] DEBUG com.datastax.driver.core.Connection - Со…
08 окт '16 в 01:09
0
ответов
Отслеживание медленного выполнения запроса "Неверное количество переменных связывания"
Я пытаюсь отследить некоторые медленно работающие запросы на моем кластере в OpsCenter 5.2.1, DSE 4.8.10. Каждый запрос, который я пытаюсь отследить в службе производительности opscenter, выдает одну и ту же ошибку: com.datastax.driver.core.exceptio…
08 ноя '16 в 13:48
1
ответ
Невозможно импортировать org.apache.spark.sql.cassandra.CassandraSQLContext
У меня на пути есть spark-cassandra-connector_2.11-2.0.0-M3.jar, но я все еще не могу импортировать org.apache.spark.sql.cassandra.CassandraSQLContext. Это в каком-то другом пакете - вся документация указывает на этот пакет (или устарела). Спасибо
03 янв '17 в 20:46
1
ответ
java.lang.VerifyError: исключение AbstractEpollUnsafe в приложении Vertx, Dse
Я пытаюсь запустить приложение, которое использует библиотеку Datastax для DSE-графика Проект pom.xml <dependency> <groupId>com.datastax.cassandra</groupId> <artifactId>dse-driver</artifactId> <version>1.1.1-beta1…
25 янв '17 в 08:10
1
ответ
Будет ли использование отработки отказа DNS работать в качестве стратегии отработки отказа с несколькими DC?
Если у меня есть кластер с несколькими DC, DC1 и DC2 , где DC2 используется только для восстановления после отказа. А в драйвере на стороне клиента я определяю контактные точки, используя доменные имена (foo1.net, foo2.net, and foo3.net), У меня ест…
19 июл '18 в 23:46
1
ответ
Драйвер Java Datastax с защитой Kerberos
Я пытаюсь получить доступ к Kerberos с включенным DSE кластером из Eclipse. Пример кода подключения public void connect(String node) { cluster = Cluster.builder().addContactPoint(node) .withAuthProvider(new DseAuthProvider()).build(); Metadata metad…
29 янв '14 в 03:34
1
ответ
Сбой на удаленном соединении OLAP в консоли gremlin: невозможно создать источник прохождения OLAP, когда искра не работает или не может быть обнаружена
В соответствии с: https://docs.datastax.com/en/latest-dse/datastax_enterprise/graph/graphAnalytics/northwindDemoGraphSnapshot.html Я подключился в режиме OLAP и получил вышеуказанный сбой. Я сделал "dse spark", успешно. Но я не понимаю, почему я не …
01 дек '16 в 07:46
1
ответ
Сетевые осведомленные удары
Каковы сетевые доносы в Кассандре? Они указали, что NetworkToplogy может использоваться только с сетевыми срезами. Так какие же стукачки могут использовать NetworkTopology?
08 ноя '14 в 15:03
1
ответ
Чтение исключения тайм-аута в Кассандре с использованием cassandra-driver-core
Я пишу Java-приложение, которое считывает данные из MySQL и сохраняет их в Cassandra, поскольку Sqoop не поддерживает прямой импорт в Cassandra. Я использую платформу Producer-Consumer для достижения того же самого из-за большого количества записей …
14 май '14 в 09:21
2
ответа
InvalidQueryException при попытке создать семейство столбцов в Cassandra с помощью модуля
У меня есть 3-х узловый кластер кассандры, и с помощью моего модульного теста в Java я сначала создаю пространство ключей, а затем создаю семейство столбцов в этом пространстве ключей. Иногда юнит-тесты проходят, но случайно я получаю следующую ошиб…
28 янв '15 в 23:31
2
ответа
Невозможно построить базу данных стресс-клиентов cassandra с помощью DataStax
Я работаю с моим собственным кластером базы данных с Кассандрой. Я хочу попробовать стресс-тесты с моей базой данных, поэтому я скачал Java-драйвер DataStax для Cassandra. https://github.com/datastax/java-driver После того, как я скачал его, я узнал…
19 май '13 в 20:45
1
ответ
Лучшие практики для настройки уровня согласованности и коэффициента репликации для Cassandra
Если для коэффициента репликации и уровня согласованности задано значение QUORUM, то мы можем достичь доступности и согласованности, но при увеличении числа узлов снижение производительности будет увеличиваться. Это утверждение правильно? Если да, т…
16 июл '18 в 16:54
1
ответ
Проблема уровня согласованности данных Cassandra
Я создаю объект сеанса cassandra для своего приложения и создаю несколько подготовленных операторов для него. Установка разных уровней согласованности для каждого подготовленного утверждения. statement1 = session.prepare("SELECT key FROM foo WHERE k…
15 фев '18 в 23:15
1
ответ
Кодек не найден для запрошенной операции: [отметка времени <-> java.util.UUID]
У меня есть таблица в Кассандре, которую я пытаюсь перебрать и извлечь из нее материал. Я использую datastax Java-драйвер 3.1.0. CREATE TABLE test ( client_id int, process_id text, last_modified_date timestamp, PRIMARY KEY ((client_id), process_id) …
23 ноя '16 в 06:58