Spark потокового обмена данными между пакетами

Как отфильтровать поток данных с помощью операции преобразования и внешнего RDD?

я использовал

Spark Streaming в каталоге S3

добавление языкового фильтра в твиттер популярные хэштеги - scala

Что означает «потоковая передача» в Apache Spark и Apache Flink?

Как я пошел вApache Spark Streaming На сайте я увидел предложение:Spark Streaming позволяет легко создавать масштабируемые отказоустойчивые потоковые приложе...

Ошибка «Соединение отказано» при запуске Spark Streaming на локальном компьютере

Я знаю, что уже есть много тем, связанных с отказом от потокового соединения. Но большинство из них в Linux или, по крайней мере, указывают на HDFS. Я запуск...

Будет ли какой-нибудь сценарий, когда Spark RDD не сможет удовлетворить неизменность?

СДР зажигания сконструированы в неизменном, отказоустойчивом и отказоустойчивом виде.Удовлетворяет ли СДР неизменность во всех сценариях? Или есть какой-то с...

Spark Streaming на EC2: Исключение в потоке «основной» java.lang.ExceptionInInitializerError

Я пытаюсь запустить spark-submit для файла JAR, который я создал. Когда я запускаю его локально на моей машине, он работает правильно, но при развертывании н...

Как я могу обновить широковещательную переменную в потоковой передаче искры?

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

spark-submit: --jars не работает

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