Мое приложение для потоковой передачи в режиме искры читает из 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. Вот...
Я написал приложение для потокового воспроизведения, которое использует данные, хранящиеся в теме...