Я разрабатываю скрипт прогнозирования Python с использованием потоковой передачи Spark (PySpark) и...

У нас есть поток Кафка, который использует Avro.Мне нужно подключить его к Spark Stream.Я использую...

В чем разница между никогда не останавливать SparkContext и StreamingContext? DStream имеет...

Я довольно новичок в потоковом программировании.У нас есть Kafka Stream, который использует Avro. Я...

Я новичок в Scala / Spark Streaming и в StackOverflow, поэтому прошу прощения за мое форматирование

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

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

У нас есть выходная пакетная обработка, которая работает, как указано ниже Hive SQL используется...

У меня есть потоковое задание Spark, которое объединяет строки, используя идентификатор и временное...

Для первого сценария я хочу использовать Spark Structured Streaming с Iot Hub на входе и Cosmos DB...

Я пытаюсь проверить функциональность потоковой передачи искры и хотел бы видеть, что DStreams - это...

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

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

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

Я пытаюсь оптимизировать приложение Spark Streaming, которое собирает данные из кластера Kafka,...

У меня есть несколько локальных серверов разработки с обратной связью, которые я использую в Centos...

Я пытаюсь использовать Kafka 0.10.2 в моем проекте Spark Streaming (который использует библиотеку 1

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

Моя идея состоит в том, чтобы использовать Spark Streaming + Kafka для получения событий от шины...

Попытка достижения высокой доступности SparkMaster с помощью ZooKeeper с отказоустойчивостью...

Я пытаюсь прочитать CSV-файлы из определенной папки и записать то же содержимое в другой CSV-файл в...

Я довольно новичок в упругом поиске.Я использую elasticsearch-hadoop 6.2.4 версию, и я читаю файлы...

Итак, у меня проблема с Kafka Sinks в Spark Streaming при отправке JSON для нескольких тем и...

Использование Spark потоковой передачи (записано в Scala ) для чтения сообщений от Kafka.Все...

Я пытаюсь выполнить сценарий спарк с помощью следующей команды. spark-submit --packages org.apache