datastax-java-driver

0зной

1ответ

Как читать все строки из огромной таблицы в кассандре?

У меня есть кластер Cassandra с двумя узлами и replica_factor = 2 в том же центре данных. Таблица в ~ 150 миллионов и постоянное увеличение, что мне нужно прочитать процесс и обновить соответствующую

4зной

2ответ

Каков наилучший способ получить противодавление для Cassandra Writes?

У меня есть служба, которая расходует сообщения из очереди со скоростью, которую я контролирую. Я делаю некоторую обработку, а затем пытаюсь написать кластер Cassandra через клиент Java Datastax. Я ус

1зной

1ответ

Подготовленное заявление Cassandra и добавление новых столбцов

Мы используем кешированный PreparedStatement для запросов к DataStax Cassandra. Но если нам нужно добавить новые столбцы в таблицу, нам необходимо перезапустить наш сервер приложений, чтобы обновить п

0зной

1ответ

Cassandra первичный ключ зачатие

CREATE TABLE c1.ticket ( uuid int PRIMARY KEY, idflycompany int ) WITH bloom_filter_fp_chance = 0.01 AND caching = {'keys': 'ALL', 'rows_per_partition': 'NONE'} AND comment = ''

4зной

1ответ

Как заменить JAVA-контур с помощью Direct Spark Cassandra Table Data Manipulation

Я пытаюсь сделать мой код более эффективным, так как мне приходится обрабатывать миллиарды строк данных в кассандре. В настоящее время я использую цикл JAVA в Datastax Cassandra Spark Connector чтобы

0зной

1ответ

Spark - Сопоставление столбцов с переменными в JAVA из RDD или DataFrame

Я пытаюсь сопоставить столбцы строк cassandra в Spark RDD с переменными, которые я могу перебирать для манипуляций внутри искры, но, похоже, не может их превратить в переменная. У меня есть следующий

0зной

1ответ

Повторить все хосты навсегда?

У меня есть некоторые данные, которые должен быть записан в Кассандру. Первоначально я думал, что это будет просто, просто настроив RetryPolicy для ReadTimeout, WriteTimeout, Unavailable и RequestErro