spark-cassandra-connector

1зной

1ответ

Кассандра показывает разные результаты в разных сериях

Я заработал 200 миллионов записей в кассандре от искры. Использование разъема spark-cassandra. У меня возникли следующие две проблемы. Извините, тема относится только к одному вопросу. 1) com.datastax

2зной

1ответ

Свеча работает на Кассандре терпит неудачу из-за ClassNotFoundException: com.datastax.spark.connector.rdd.partitioner.CassandraPartition (подробности внутри)

Я использую spark 2.0.0 (локальный автономный) и spark-cassandra-connector 2.0.0-M1 с scala 2.11. Я работаю над проектом на IDE и каждый раз, когда я бегу искровые команды я получаю ClassNotFoundExcep

1зной

1ответ

Как перенести изменение столбца кластера классандры

У нас есть прецедент, чтобы изменить столбец таблицы cassandra (изменить тип от Int до Long), так как он не поддерживается при переходе из Int в varInt, и мы в порядке с этим. Но в некоторых таблицах

1зной

2ответ

Spark 2.0 Cassandra Scala Shell Ошибка: java.lang.NoClassDefFoundError: scala/collection/GenTraversableOnce $ class

Я настроил оболочку искры 2.0 для работы с коннектором datastax cassandra. spark-shell --packages datastax:spark-cassandra-connector:2.0.0-M1-35-s_2.11 При выполнении этого фрагмента кода в оболочке

0зной

1ответ

Как использовать Java-коннектор для Cassandra для получения данных из зависимых семейств столбцов

Я изучаю Apache Spark, Cassandra 3.7 и Java-разъем Datastax для Cassandra. Это может быть совершенно глупый и наивный вопрос для вас, но я не получаю правильный способ справиться с этим из документаци

0зной

3ответ

Почему Datastax Spark Cassandra Connector 2.0 не может быть построен из источников для Scala 2.11?

Я пытаюсь построить Datastax Spark-Cassandra Connector 2.0 из источников, для Scala 2.11. Планирование использования с Spark 2.0. Клонирование этого репозитория (мастер): https://github.com/datastax/s

0зной

1ответ

Ошибка запроса cassandra нет жизнеспособной альтернативы на входе «ALLOW»

Я пытаюсь запустить запрос на Cassandra через искру. При выполнении этой команды: val test = sc.cassandraTable[Person](keyspace,table) .where("name=?","Jane").collect я получить соответствую

0зной

1ответ

Вопрос о степени непротиворечивости Кассандры

У нас есть 3 узла кластера Cassandra с репликацией 3. некоторое время назад Кассандра (1 Узел) опускается на 2 дня. Теперь мы Невозможно читать данные из Cassandra кластера некоторое время мы получаем

1зной

2ответ

Задача не сериализации: Вызванная java.io.NotSerializableException org.apache.spark.SparkConf

я пытаюсь использовать некоторые данные из базы данных Cassandra с помощью разъема искры Кассандры, но я падаю на этой ошибке: org.apache.spark.SparkException: Task not serializable . . Caused by:

0зной

1ответ

Как вызвать DataFrameFunctions.createCassandraTable с Java?

Как я могу назвать эту функцию с Java? Или мне нужна обертка в scala? package com.datastax.spark.connector class DataFrameFunctions(dataFrame: DataFrame) extends Serializable { ... def create