Я хотел бы сохранить потоковый фрейм данных, который получает "обновление". Для этого я буду...

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

Я пытаюсь прочитать поток orc в java: Набор данных d2 = sparkSession.readStream (). Format ("orc")

//Streaming read from Kafka val df = spark.readStream .format("kafka") .option("kafka

Может быть, вопрос слишком прост, по крайней мере, так, но у меня есть следующая проблема: A

Я экспериментирую с сердцебиением при запуске приложения Spark Streaming. Я знаю значение...

Я работаю над фреймворком, который может принимать входные данные в виде набора файлов,...

У меня есть приложение для потокового воспроизведения, которое извлекает записи журнала из Kafka и...

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

Я читаю исходный код Spark Streaming в части Кафки.Существует алгоритм управления скоростью,...

См. Изображение ниже, чтобы проверить график концентратора событий. Изображение Невозможно получить...

Я имею в виду очень простой код Spark Streaming Scala.Код указан ниже import org.apache.spark

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

Я использую Spark со Scala, и у меня есть каталог, в котором у меня есть несколько файлов. В этом...

Я пытаюсь транслировать содержимое локального каталога в HDFS.Этот локальный каталог будет изменен...

Попытка сделать некоторую манипуляцию с потоковой передачей и для этого нужно использовать функцию

[New to Spark] У нас есть приложение Spark Streaming, которое читает из Kinesis и пишет в Redshift....

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

У меня есть потоковое приложение Spark + Kafka, которое отлично работает в локальном режиме, однако...

Я выполнил следующие операции над rdd с 4-мя разделами в функции foreachRDD DStreams моего...

Я пробовал библиотеку pygmalios / реактивныйinflux-spark , но ее зависимость подвержена ошибкам с...

Здравствуйте, я написал следующий код val receivedStream: DStream[PubsubSparkMessage] =...

Я пытаюсь выполнить потоковое воспроизведение с помощью Spark.Модель, которую он строит, но я не...

У меня есть простой код Spark Streaming, который я хочу попробовать: import org.apache.spark

Когда я запускаю приложение для потокового воспроизведения, можно ли получить лучшее время...