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

При получении кода структурированной потоковой передачи Spark появляется следующее исключение:...

Я читаю данные из потокового источника MQTT с помощью Spark Structured Streaming API. val lines:=...

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

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

Мы разработали потоковое структурирование с поддержкой искры, которое обрабатывает миллиарды...

Я пытаюсь использовать EventHubsForeachWriter, как показано здесь : val ehConf =...

Я пытаюсь запустить очень простой пример.У меня есть Кафка readStream, которая читает из темы Кафки

Как RDD создаются в структурированной потоковой передаче в Spark?В DStream у нас есть для каждого...

Я новичок в теме потоковой передачи.Таким образом, возникает проблема при расчете различного числа...

Я работаю с Apache Spark 2.4 и читаю данные json из kafka после применения многократного...

У нас есть потоковое приложение с искровым структурированием, работающее в производстве с...

Я использую Йену в Spark.Я сталкиваюсь со странной проблемой при развертывании в кластере (не...

Попытка записи данных в тему Kafka с использованием Spark Structured Streaming и получение...

У меня проблема с передачей данных в Kafka с помощью фрейма данных Spark. Позвольте мне объяснить...

У меня есть кластер Spark с 17 исполнителями. Я интегрировал Spark 2.1 с Kafka и читаю данные из...

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

Почему для первого триггера "среднее" значение потоковой передачи sql равняется нулю? Пробовал как...

Я искал, как записать результаты структурированного потока в s3, но не смог найти способ сделать...

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

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

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

У меня есть тема на Кафке, которую я потребляю, и я использую from_json для преобразования...

Я занимаюсь разработкой структурированного приложения Spark Stream, в котором после анализа я...

Я использую Kafka 0.9.0 и Spark 2.1.0 My Spark Submit следующим образом: ./spark-submit --jars...