В моем приложении структурированного потокового вещания я читаю сообщения от Кафки, фильтрую их и,...

мы хотим читать данные из kafka, которые дают данные 70 и т. Д. За 500 мс со структурированной...

Мое требование - прочитать объекты json из kafka и для каждой записи выполнить поиск в кэше redis и...

Для приложения My Spark 2.4.x (pyspark) требуется: Входные данные - это две темы Kafka, а выходные...

Время выполнения Режим кластера YARN Приложение Структурированная потоковая передача Spark Чтение...

В настоящее время, когда я использовал Structured Streaming v2.1.0 + Kafka v0.10 для обработки...

Я использую пример потоковой структурированной искры "https://github

Я пытаюсь распаковать значения сообщения Kafka в экземпляры класса case.(Я помещаю сообщения на...

Искра версия 2.3.3 Я хочу подключиться к mqtt, используя аргумент --packages в spark-shell...

Я использую spark 2.4 и запускаю pyspark следующим образом: ./bin/pyspark --packages org.apache

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

Spark 2.4.0 поддерживает Python UDF с режимом непрерывной обработки? В моем простом коде я...

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

Приложение My Spark Structured Streaming запускается в течение нескольких часов, прежде чем выходит...

У меня возникли вопросы по отказоустойчивости в Spark Structured Streaming при чтении с kafka. Это...

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

Мне кажется, что-то не хватает в Stream - Статическое соединение в Spark 2.2. В руководстве...

У меня есть приложение для потокового Python со структурой pyspark, настроенное так: from pyspark

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

Мне нужен набор данных из запроса к базе данных (источник данных JDBC), который содержит все строки...

Я использую данные из темы кафки через структурированную потоковую передачу, в теме 3 раздела

У меня есть тема Kafka с 3 разделами, и я использую эти данные с использованием потоковой...

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

У меня есть простые данные в формате json от kafka следующим образом:...

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