Я слежу за потоковой игрой Spark . Вместо использования nc -lk 9999 я создал свой собственный...

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

Получение нулевых исключений или никаких действий при попытке использовать искру под foreachrdd и...

Мое приложение для потоковой передачи в режиме искры читает из kafka с использованием подхода...

Я получаю DStream от Кафки и хочу сгруппировать все сообщения в каком-то скользящем окне по ключам....

Я пытаюсь понять внутреннюю часть потоковой передачи Spark (не структурированной потоковой...

Мы пытаемся обработать данные, полученные из сокета pyspark (версия 2.3.2), который работает по...

Я могу создать DF внутри foreachRDD, если я не попытаюсь использовать Класс Case и просто позволю...

Озадаченный частью кода, который я позаимствовал из Интернета для исследовательских целей. Это код:...

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

Я пишу программу для приема данных.Для чтения из Kafka в DStream разделите Dstrem на 3 потока и...

У меня есть данные JSON, как показано ниже "symbol": "xxxx",...

Я боролся за объединение DStream и RDD. Чтобы установить сцену: Искра - 2.3.1 Python - 3.6.3 РДД Я...

Вот мой код: ssc =streamingcontext(sparkcontext,Seconds(time)) spark = sparksession.builder

Я сталкиваюсь со следующей ошибкой: Я написал приложение, основанное на потоковой передаче Spark (...

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

Я получаю данные от кафки в виде {"email":"test@example"...

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