Я пытаюсь прочитать поток, используя мой пользовательский источник данных (v2, используя spark 2.3)...

Я пытаюсь выполнить эти искровые операторы, но это не работает spark.sql("CREATE OR REPLACE...

Я хотел бы подтвердить, можно ли / хорошо читать два разных файла CSV как структурированные потоки...

У меня есть два потоковых фрейма данных - firstDataFrame и secondDataframe.Я хочу, чтобы поток...

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

У меня есть приложение Spark Streaming, которое считывает имена таблиц Hive в записях Kafka,...

, поэтому я борюсь с данными kafka json, используя потоковую передачу по искрам, и застрял в...

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

Я получаю следующую проблему, когда присоединяюсь к 2 DF в потоковой передаче искры.Не могли бы вы...

До сих пор у нас есть приложение для пакетной обработки, в котором мы просили источник сообщить нам...

Я новичок в spark, я пытаюсь прочитать таблицу из оракула в hdfs файл parquet farmat ... Моя...

Я столкнулся с одной проблемой при выполнении spark sql поверх потоковой обработки spark. Я не...

Я пытаюсь преобразовать RDD в DataFrame в Spark Streaming.Я слежу за процессом ниже. socket_stream...

Я загружаю данные во фреймы данных, где один из столбцов равен zipCode (String type). Интересно,...

Я новичок в MongoDB, не могли бы вы преобразовать ниже SQL в запрос MongoDB SELECT ID, country,...

{"cust": "Розничная торговля", "таблицы": [ { "Name":"customer",...

Я реализовал специальный приемник Spark для приема DStreams из http / REST следующим образом val...

Мне нужно написать Spark SQL-запрос с внутренним выбором и разделить на. Проблема в том, что у меня...

У меня есть слушатель искры, как показано ниже; public class MySparkListener extends SparkListener...

Продолжение до этого вопроса У меня потоковая передача данных в формате json, как показано ниже | A...

У меня есть потоковые данные JSON, структуру которых можно описать с помощью класса case ниже case...

Что у нас есть stream.foreachRDD(rdd->{ JavaRDD<String> javaRDD=rdd.map(elem -> elem

У меня есть требование, в котором мне нужно прочитать сообщение из темы kafka, выполнить поиск в...

Привет, я новичок в Flume / Spark / Spark Streaming.Я настроил flume и netcat и успешно передал...

Я пытаюсь обновить несколько полей в документе mongodb через Spark.Я извлек поля из другого фрейма...