Мое приложение для потоковой передачи в режиме искры читает из kafka с использованием подхода...

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

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

У меня есть требование добавить спящий оператор, если я не могу использовать сообщение и хочу...

У меня есть два потока данных, и я присоединяюсь к ним каждую минуту.Те записи, которые не...

Мой конвейер данных выглядит следующим образом: Kafka => выполнить некоторые вычисления =>...

Обобщения всегда сообщают об ошибке во время инициализации, выводят «Неуказанные параметры типа: R»...

Await.result (observableDoc.toFuture, Duration.Inf) дает нулевое значение в искровом кластере. Он...

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

Я пытаюсь преобразовать мой dstream в Dataframe. Вот код, который используется для преобразования...

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

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

Я делаю потоковую искру от Кафки.Я хочу преобразовать мой rdd из kafka в dataframe.Я использую...

Scala Spark Streaming не подключается к темам Kafka и чтению сообщений.В журналах ошибок искры нет...

В какой-то момент я знаю, что в поток больше не приходят сообщения.Как я могу определить, что все...

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

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

В моем структурированном потоке я установил водяной знак на 1 час. Я выполняю оконную операцию...

Поскольку dji предоставил поддержку для миссии путевой точки искры dji во второй последней версии...

Прежде всего, я новичок в Spark Streaming и мне нужна помощь.У меня есть JavaPairDStream, как...

Я пытался записать потоковые данные из концентратора событий в BLOB-объекты в Azure Databricks. Это...

У меня есть array[array], который я заполняю данными, поступающими с stream.Мой batch interval...

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

Я пытаюсь использовать isTimingOut для удаления состояния и отправки его в выходной Dstream. Вот...

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