Я новичок в потоковом воспроизведении и просто знаю функцию updateStatebyKey(). Я хочу спросить,...

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

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

Чтобы ускорить доставку видео на моей платформе, я разбил загруженные носители на сегменты...

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

Я отправляю задание Python Spark Streaming с использованием spark-submit. spark-submit hashtagTrend

Моя проблема в том, что я не могу напечатать данные, собранные с Kafka, потому что, когда я пытаюсь...

Я получаю исключение InterruptedException в методе Спарка rdd.collect(). Трассировка стека: java

Я пытаюсь работать со встроенным кодом Apache Spark с интеграцией Kafka для онлайн-кода k-средних с...

Я получаю это исключение при запуске задания на искру: Exception in thread "main" org

Spark Streaming от Kafka с чувствительной к последовательности обработкой: обработка неточна, когда...

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

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

Согласно документу «Модель потока данных»: практический подход к балансу между корректностью,...

Я пытаюсь передать данные из API, который описан здесь https://opensky -network.org / apidoc / rest

Как я могу объединить или объединить статический фрейм данных только с одной строкой в ​​потоковый...

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

Я хочу кэшировать некоторые данные (ndarrays) локально на рабочих узлах, чтобы провести некоторое...