Spark Streaming: HDFS

Я не могу получить задание Spark для потоковой передачи «старых» файлов из HDFS.Если по какой-то причине мое задание Spark не работает (например, демонстраци...

Невозможно отправить задания в спарк кластер (режим кластера)

Spark версия 1.3.0Ошибка при отправке заданий в спарк кластер в режиме кластера

Как установить и получить статические переменные от спарк?

У меня есть класс как это:

Настраиваемое участие JavaDStreamPairRDD

В потоковой передаче Spark, каков рекомендуемый способ реализации настраиваемого участника на DStreams?Я использовал JavaPairRDD.partitionBy (Partitioner) в ...

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

Spark Python Авро Кафка Десериализатор

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

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

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

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

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

Остановите потоковый контекст в Spark Streaming через некоторое время

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