Описание тега cassandra-jdbc

Описание тега Вопросы с тегом
A JDBC-compliant driver for Cassandra using CQL.
1 ответ

Ошибка при вставке данных в Cassandra

Я изучаю Apache Kafka-шторм-Кассандра интеграции. Я читаю строку JSON из кластера Kafka, используя Kafka Spout. Затем передаю ее болту, который анализирует JSON и выдает необходимое значение во второй болт, который записывает его в базу данных Cassa…
15 июн '15 в 10:14
1 ответ

Транзакционные операции в Кассандре

Мы оцениваем No SQL DB для нашего приложения, и Cassandra хорошо работает для большинства операций, которые мы делаем. У нас могут быть транзакционные операции на Cassandra, хотя мы планируем, что RBMS дополняет Cassandra для выполнения всех транзак…
23 авг '16 в 15:04
1 ответ

Неожиданный тайм-аут соединения в dasastax cassandra -com.datastax.shaded.netty.channel.ConnectTimeoutException

Мы получаем соединение в объекте Session при первом запуске приложения. Наш планировщик продолжает вставлять данные в Cassandra, используя это. но в какой-то момент времени тайм-аут получения соединения, а затем повторное соединение с Cassandra и пр…
19 авг '15 в 04:35
2 ответа

Ошибка аутентификации на хосте /127.0.0.1: аутентификация SASL не поддерживается в версии 1 протокола

Получение следующего исключения при подключении к Cassandra Cluster с помощью аутентификации: Исключение в потоке "main" com.datastax.driver.core.exceptions.AuthenticationException: ошибка аутентификации на хосте /127.0.0.1: аутентификация SASL не п…
30 дек '13 в 14:54
1 ответ

Время ожидания чтения Кассандры в 5-минутном интервале последовательно?

Может кто-нибудь объяснить, почему в моем кластере Cassandra могут возникать тайм-ауты чтения каждые 4-5 минут. Я почти мог видеть это последовательно и быть в состоянии воспроизвести это последовательно. Пропускная способность чтения поддерживалась…
13 май '15 в 06:52
0 ответов

Соедините Beam JDBC IO с Кассандрой

Невозможно соединить Cassandra с помощью драйвера jdbc, получающего ошибку java.sql.SQLException: невозможно создать PoolableConnectionFactory (isValid() вернул false) Apache Beam JDBC IO не работает с Casandra. Я пытался работать с cassandra-jdbc-1…
04 фев '19 в 11:30
1 ответ

Драйвер Java Cassandra с защитой Kerberos

Пытаюсь подключиться из Java-драйвера Datastax к защищенному кластеру cassandra с включенным Kerberos. Пример кода подключения: cluster = Cluster.builder().addContactPoint(node).withCredentials("username","password").build(); Metadata metadata = clu…
15 окт '13 в 03:47
0 ответов

Получить полное название квалификационной колонки в Кассандре

Ниже приведен пример схемы базы данных на Кассандре. CREATE TYPE TypeAddress( Column1 INT, Column2 INT, Column3 INT ); CREATE TABLE TablePersonInfo( ColumnA INT, ColumnB INT, TypeAddress_ FROZEN<TypeAddress> ); CREATE KeySpace KSName; Я хочу п…
28 дек '16 в 17:06
1 ответ

Как установить / инициализировать значения для нового добавленного столбца в Cassandra

У нас в Кассандре более 10 миллионов строк, и все они находятся под одной таблицей. Недавно мы планируем добавить новый столбец в существующую таблицу, и новый столбец для всех строк должен быть установлен как true, Есть ли способ инициализировать з…
06 май '15 в 17:09
1 ответ

Вставьте изображение в бланк кассандры, используя Java

Я хочу вставить изображение в виде байтового буфера в таблицу кассандры. Таблица: Сотрудники (Имя, текст, изображение) Я сохранил изображение в переменную bb в виде байтового буфера, используя Java. Как вставить данные из этого байтового буфера bb в…
26 окт '16 в 14:35
2 ответа

СОЗДАЙТЕ KEYSPACE, ЕСЛИ НЕ СУЩЕСТВУЕТ В CQL

Я использую ниже синтаксис CQL для создания пространства ключей, только если не существует: CREATE KEYSPACE IF NOT EXISTS Test WITH replication = {'class':'SimpleStrategy', 'replication_factor':1}; но это дает ошибку: Exception in thread "main" com.…
27 мар '14 в 15:55
2 ответа

Как конвертировать Cassandra UDT в Дополнительный тип

У меня есть таблица User и соответствующий ей POJO @Table public class User{ @Column(name = "id") private String id; // lots of fields @Column(name = "address") @Frozen private Optional<Address> address; // getters and setters } @UDT public cl…
11 янв '16 в 12:05
1 ответ

Настройка Cassandra в качестве основного хранилища данных на WSO2 Identity Server

Мы установили WSO2 Identity Server 4.6.0 и хотели бы использовать Cassandra как основное хранилище данных, а также менеджер хранилища пользователей. Мы не нашли четкого пути для реализации этого. Кто-нибудь может дать нам четкий путь о том, как наст…
24 фев '14 в 21:02
2 ответа

Datstax Cassandra Навальный загрузчик

Я пытаюсь использовать JMX BulkLoader для передачи данных ETL в Cassandra с удаленного узла на кластер https://github.com/PatrickCallaghan/datastax-analytics-example/blob/master/src/main/java/com/datastax/jmxloader/JmxBulkLoader.java Однако после ус…
29 ноя '14 в 00:44
1 ответ

CQL SELECT завершается ошибкой с prepareStatement

В моем примере приложения следующий фрагмент работает нормально. SELECT_CQL = "SELECT * FROM " + STREAM_NAME_IN_CASSANDRA + " WHERE '" + CONTEXT_ID_COLUMN + "'=?"; Connection connection = getConnection(); statement = connection.prepareStatement(SELE…
30 янв '14 в 12:27
1 ответ

Кассандра JDBC ошибка

Я пытаюсь подключиться к Cassandra 2.0.3 с помощью cassandra-jdbc-1.2.5. Но это дает ошибку: Любое решение? Исключение в потоке "main" java.lang.NoSuchMethodError: org.slf4j.impl.StaticLoggerBinder.getSingleton()Lorg/slf4j/impl/StaticLoggerBinder; п…
24 апр '14 в 11:58
1 ответ

Разработка первичного ключа Cassandra для удовлетворения запросов диапазона

Я разработал семейство колонн текст prodgroup, prodid int, status int,, PRIMARY KEY ((prodgroup), prodid, status) Модель данных предназначена для обслуживания Получить список продуктов из группы продуктов получить список продуктов для данного диапаз…
21 дек '14 в 10:23
1 ответ

Кассандра Таймсери Датамодель

Предположим 10 устройств (dev01,dev02,dev03..etc). Он отправляет данные с некоторым интервалом времени, мы собираем эти данные, поэтому наша схема данных dev01 :int signalname :string signaltime :date/time[with YY-MM-DD HHMMSS.mm] Extradata :String …
01 авг '13 в 07:41
0 ответов

DataStax Alwayson Passthrough Security НЕ работает

Я пытаюсь всегда настроить безопасность в dasastax cassandra. Но запросы выполняются как Alwayson_sql. Кроме того, пользователь, используемый в соединении jdbc, на самом деле НЕ проверяется. Он регистрирует меня, независимо от того, какой пароль мы …
25 сен '18 в 00:51
0 ответов

Огромное падение производительности в кассандра-орме после миллиона записей

Я использую плагин cassandra-orm (cassandra-orm: 0.4.5) для переноса кликов из Postgres DB в Cassandra. (Я знаю, что мог бы использовать импорт необработанных данных, но я хочу использовать groupBy и явные индексы, поддерживаемые плагином). Процедур…
02 июн '15 в 14:02