spark-cassandra-connector

0зной

1ответ

Как создать «CassandraTableScanRDD» без sparkContext

Я работаю с искровым потоком & cassandra connector, и у меня есть некоторый эквивалентный класс dao (работающий с Scala). на этом dao, я хочу создать «CassandraTableScanRDD». Проблема в том, что у мен

0зной

1ответ

Ошибка обработки ошибок в Spark Cassandra Connector

У меня есть приложение Spark Streaming, которое имеет несколько потоков данных (DStreams), которые пишут в той же таблице Cassandra. При тестировании моего приложения на большом количестве случайных д

1зной

1ответ

искровым Cassandra Connector бросает InvalidQueryException

Я столкнулся эту ошибку: трассировки стека: 16/09/22 12:35:01 ERROR QueryExecutor: Failed to execute: [email protected] com.datastax.driver.core.exceptions.InvalidQueryException: Key length of 105500

3зной

2ответ

Spark-cassandra-connector: toArray не работает

Я использую разъем spark-cassandra с Scala, и я хочу читать данные из cassandra и отображать его с помощью метода toArray. Однако я получаю сообщение об ошибке, что оно не является членом класса, но у

0зной

3ответ

Cassandra стол надгробия не 0

У меня есть проблемы с Кассандрой: если я nodetool -h 10.169.20.8 cfstats name.name -H Я получаю результаты и статистика выглядит так: Read Count: 0 Read Latency: NaN ms. Write Count: 739812