Я использую spark-структурированную потоковую передачу в качестве потребителя для получения данных...

Я пытаюсь записать данные в HDFS из структурированного потокового кода в Scala. Но я не могу этого...

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

У меня есть очень простое и простое приложение, в котором у меня есть тема1 и тема2, потоковое...

Мой источник данных - Кафка, и я читаю данные из Кафки следующим образом: var df = spark

Я использую структурированную потоковую передачу для чтения csvs и записи в kafka. Вкладка...

Я работаю со Spark Structured Streaming.Также я работаю с Scala.Я хочу передать конфигурационный...

У меня есть скрипт на python, который каждую минуту получает данные о запасах (как показано ниже)...

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

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

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

Я пытаюсь обработать потоковые avro-данные из kafka, используя структурированную потоковую...

Есть ли способ напечатать сообщение отладки Kafka (я думаю о сообщениях журнала, которые похожи на...

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

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

Я получаю сообщение об ошибке «Нет плана для EventTimeWatermark» при выполнении запроса с удалением...

Spark Structured Streaming записал результаты в kafka, но я не смог найти данные в теме Kafka,...

Рассмотрим общий вызов writeStream - с типичным «консольным» форматом вывода: out.writeStream

Я читаю поток из темы Кафки.Я выполняю оконную операцию groupBy во время события.Теперь я хочу...

Я пытаюсь интегрировать Kafka с Spark-Structured-Streaming в приемник MongoDB.Мне нужна помощь по...

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

У меня есть потоковое потоковое приложение, которое читает данные из kafka и записывает их в hdfs.Я...

Моя структурированная потоковая работа Spark непрерывно генерирует файлы паркета, которые я хочу...

Я использую потоковую обработку искры с приемником foreach для обработки данных iot-пакета. Мне...

Я читаю 2 потока (stream1 & stream2) из ​​Kafka в потоковой структурированной искре (pyspark). Я...