spark-cassandra-connector

1зной

1ответ

Можно ли импортировать/копировать несколько файлов в таблицу acassandra, которые имеют одинаковое имя столбца в таблице и в файлах? COPY table1 (timestamp, temp, total_load, designl) FROM 'file1', 'fi

0зной

1ответ

Какая версия должна использоваться для соединителя Spark Cassandra.?

Я смущен и хочу знать, какую версию я должен использовать для разъема spark-cassandra, версии Cassandra Driver и Scala. Любая помощь будет оценена.

0зной

1ответ

Cassandra Spark Connector

У моей cassandra CF есть дата и идентификатор в качестве ключа раздела. во время запроса Я знаю только дату, поэтому я перебираю диапазон идентификаторов. Мой вопрос вращается вокруг того, как соедини

2зной

2ответ

Невозможно сериализовать SparkContext в foreachRDD

Я пытаюсь сохранить потоковые данные в cassandra из Kafka. Я могу читать и анализировать данные, но когда я вызываю строки ниже, чтобы сохранить данные, я получаю исключение Task not Serializable. Мой

0зной

2ответ

Спарк Streaming Фильтрация данных Streaming

Я пытаюсь фильтровать потоковые данные, и на основе значения столбца идентификаторов я хочу, чтобы сохранить данные в разных таблицах У меня есть две таблицы testTable_odd (идентификатор, data1, data2

3зной

1ответ

Как сохранить org.apache.spark.mllib.linalg.Vector в dataframe для cassandra

У меня есть требование сохранить файл данных, который содержит org.apache.spark.mllib.linalg.Vector в одном из столбцов. Создавая таблицу в кассандре из фреймворка данных, она бросает ошибку. java.lan

0зной

1ответ

пакетная вставка с использованием разъема искры cassandra для Scala

Im пытается вставить некоторые строки в cassandra с помощью оператора партии. Я не смог найти документацию о том, как это сделать с помощью искрового разъема datastax. Я попытался следующие CassandraC

2зной

3ответ

Что происходит - NoSuchMethodError: com.datastax.driver.core.ResultSet.fetchMoreResults

cassandra-connector-assembly-2.0.0 от github проект. с Scala 2.11.8, cassandra-driver-core-3.1.0 sc.cassandraTable("mykeyspace", "mytable").select("something").where("key=?", key).mapPartitions(par =>

0зной

1ответ

Спарк Connector - не удалось получить данные при использовании списка кортежей

У меня есть следующее определение моего JavaBean public class LiveResultsFrmCassandra implements Serializable{ UUID id; String userdn; String queryid; private List<Tuple4<Strin