В elasesearch написать приемник, как мне добавить идентификатор документа с динамическими...

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

hasTimedOut метод никогда не true в моей функции обработки произвольного состояния updateState def...

Я хочу запустить задание Spark Structured Streaming локально на одной машине.К сожалению,...

Я читаю данные из раздела Kafka и помещаю их в Azure ADLS (как в HDFS) в режиме секционирования....

Я хотел вывести безопасную схему из данных JSON, полученных от Кафки. df = spark.readStream

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

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

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

Среда : Spark 2.4.0 Я включил банку spark-sql-kafka-0-10, и она той же версии, что и версия Spark,...

Есть ли способ интегрировать потоковую передачу Apache Spark с Apache Hive и Apache Kafka в одном...

Я пытаюсь перенести мои API DStream в затрудненную потоковую передачу и сталкиваюсь с тем, как...

Насколько я знаю, искровая структурированная потоковая передача - это отказоустойчивость при...

Это длинный вопрос, но я попытался подробно описать проблему. У меня есть приложение Spark на...

У нас есть поток, реализованный с помощью Spark Structured Streaming, записывающий в папку HDFS и,...

Я пытаюсь использовать тему Kafka, которая была сериализована в Avro, и мне нужно выяснить, как ее...

я работаю с zeppelin, я читаю много файлов из многих источников в потоковой передаче с плагинами:с...

Я пытаюсь портировать приложение Apache Flink (scala) на структурированную потоковую передачу Spark

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

Я пытаюсь прочитать структурированный поток, поток состоит из статистики ping: 64 bytes from vas

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

Я создал приложение с использованием структурированной потоковой передачи Apache Kafka и Apache...

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

Старый API-интерфейс структурированной потоковой передачи имеет MapWithStateDStream.stateSnapshots...

Я занимаюсь разработкой приложения Spark Structured Streaming, которое транслирует CSV-файлы и...