spark версия: 2.3 Потоковое приложение Spark осуществляет потоковую передачу по пути hdfs.И после...

Мы запускаем процесс структурированной потоковой передачи с использованием spark 2.4.3, который...

Я изучаю KeyValueGroupedDataset.flatMapGroupsWithState для произвольной агрегации с отслеживанием...

Я просматривал структурированные потоковые документы с интервалом запуска: https://spark.apache

У меня была проблема с приложением Spark структурированной потоковой передачи (SSS), которое...

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

Скажем, у меня есть некоторые потоковые данные схемы следующим образом: uid: string ts: timestamp...

Я начинаю с Structured Spark Streaming с исходным кодом Kafka и следую простому учебнику. Мой Kafka...

Я использую Apache Spark 2.4.3 и заметил, что веб-интерфейс для запроса потокового микропакета...

Прежде всего, я довольно новичок в спарке, поэтому извиняюсь, если мне не хватает очевидного! Я...

Я экспериментировал с 'flatMapGroupsWithState' со структурированной потоковой передачей Spark, идея...

Я выполняю миграцию из приложения DStreams Spark в приложение структурированной потоковой передачи

Я хочу записать все агрегированные данные из темы Кафки в файл паркета одновременно (или, по...

Я читаю данные, используя Spark Streaming из источника Kafka, откуда я создаю кадр данных со...

У меня есть два потока в моей искровой работе. Допустим, у меня есть сообщение «A», которое...

Я тестирую с использованием foreach сток структурированной потоковой передачи Spark. close() метод...

Для искровой структурированной потоковой передачи процесс чтения: sdf.writeStream

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

Я использую Spark Structured Streaming of Spark 2.4 и запускаю несколько долгосрочных потоковых...

Каталог контрольных точек для искровой структурированной потоковой передачи создает четыре...

Я новичок в Spark и пытаюсь исследовать структурированную потоковую передачу Spark.Я буду принимать...

Интересно, что (и как изменить) вызывает Spur Sturctured Streaming Query (с настроенным выходным...

Желая лучше понять выходной приемник потоковой памяти Spark Sturctured, в частности варианты...

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

Надеюсь, у тебя все хорошо. В настоящее время мы работаем над проблемой, когда нам нужно передать...