В Java у меня есть набор данных Spark (Spark Structured Streaming) со столбцом типа java.util

Я пытаюсь собрать банку, используя sbt package. build.sbt: name := "Simple Project"...

Сценарий: Cassandra размещается на сервере a.b.c.d, а Spark работает на сервере, скажем, w.x.y.z....

Я вставляю в таблицу Cassandra типичные записи строк записи Kafka, получая из-за искровой потоковой...

Как установить следующие свойства для spark-cassandra-connector версии 2.0.7: cassandra.pool.remote

Я очень новичок в Spark и Cassandra, получил один образец от GitHub и попытался запустить...

У меня есть кластер, на котором запущены Spark v1.6.1 и Cassandra V2.2.5, расположенные на каждом...

Чтобы быстрее писать в Cassandra с помощью saveToCassandra (), я делаю...

Мне нужно прочитать некоторые csv-файлы с использованием искрового фрейма данных и обработать эти...

Я использую спарк-кассандра-разъем для подключения к кассандре от искры. Я могу успешно...

Приложение My Spark обрабатывает сообщения от Кафки и записывает их в Cassandra.Через 3 часа...

Я пытаюсь сделать API Rest с помощью Akka. Одна из точек входа вернет данные из моей базы данных...

Я пытаюсь провести рефакторинг проекта, используемого в spark-cassandra, от scala_2.11 до java_1.8

Я пытаюсь записать данные фрейма данных в таблицу cassandra.Как мне отобразить структуру в...

Я использую драйвер spark-Cassandra через spark-sql для запроса моего кластера Cassandra.У каждого...

Я пытаюсь соединить искру и Кассандру, используя спарк-кассандра-разъем. соединение устанавливается...

Мы выполняем некоторое математическое моделирование данных из таблицы Cassandra с использованием...

У меня локальная установка Кассандры.Мне нужно работать в Spark с Google Colab и выполнять запросы...

Я недавно начал использовать Spark Cassandra Connector, и я вручную создал свою таблицу и смог...

У меня есть одна таблица, структура которой примерно такова -> CREATE TABLE keyspace_name

Итак, у меня есть строка искры x (тип: org.apache.spark.sql.Row), и я хочу преобразовать ее в...

У меня есть приложение, которое использует Spark (с Spark Job Server), которое использует хранилище...

Я пытаюсь создать структурированный поток из Кафки в Spark, который представляет собой строку json

Я пытаюсь загрузить искровой фрейм данных, имеющий два атрибута с типами данных коллекции, в...

Мы пытаемся соединить Cassandra с пружинным загрузчиком Cassandra Starter и Cassandra Repository. В...