Я пытаюсь запустить пример программы StructuredNetworkWordCount в структурированном потоке.Но при...

У меня возникает одна проблема при записи моего потокового фрейма с искрой в kafka.Я пишу фрейм...

Я использую данные из kafka через потоковую структурированную искру и пытаюсь записать их в 3...

Я пытаюсь объединить данные с помощью Spark Streaming.Мои данные не имеют столбца метки времени,...

Мы рассматриваем возможность использования Spark Structured Streaming в проекте.Вход и выход -...

Я знаю, что этот вопрос уже задавался несколько раз, но ни один из ответов не помог в моем случае....

Как будет работать задержка в заданиях на структурированную потоковую передачу.это создаст задержку...

У меня одно недоразумение по поводу документов Spark Structured Streaming.Я прочитал это много раз

Я пытаюсь выполнить левое внешнее соединение для потоковой структурированной искры, но строки,...

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

Я новичок в Spark и немного читал о мониторинге приложений Spark.По сути, я хочу знать, сколько...

Я использую структурированную потоковую передачу spark2.2.1, через некоторое время программа...

Я пытаюсь вставить данные в таблицу HIVE, используя метод foreach. Использую искру 2.3.0. Вот мой...

Я использую Spark 2.3.0. Моя проблема заключается в том, что всякий раз, когда я добавляю третью...

при запуске структурированной потоковой передачи с использованием lib: "org.apache.spark"...

Я собираю потоковые данные и вставляю их в папку HDFS.В определенное время я получаю данные (10000...

Вот простой код, который я использую для проверки водяных знаков: spark.readStream

Я использую структурированную потоковую передачу Spark для чтения файлов, поступающих в мою систему...

У меня ошибка при запуске примера StructuredNetworkWordCountWindowed. Error: org.apache.spark.sql

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

У меня есть две следующие схемы паркета: users: -------------------- |user_id | username|...

Я хотел бы отправить свои искровые структурированные потоковые данные в REST API. может кто-нибудь...

В настоящее время я пытаюсь использовать структурированную потоковую передачу в Scala Spark Shell....

Я использовал контрольные точки в потоковой передаче искры, и она создает отдельные папки для...

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