У меня есть следующий код: val rawWeatherStream = KafkaUtils.createDirectStream[String, String,...

Я следую вместе с кодом в Apache Spark Definitive Guide.Я столкнулся с проблемой, когда следующий...

Я на ноутбуке jupyter и хочу смоделировать сервер для отправки виртуальных данных в приложении...

Я загружаю модель машинного обучения в память в Spark и использую ее для классификации потоковых...

У меня есть приложение Spark Streaming, реализованное с помощью PySpark. Я не использую...

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

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

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

Я пытаюсь настроить поступление данных Кафки в реальном времени в HBase через PySpark в...

У меня есть сложная функция complex_function, которую я пытаюсь выполнить параллельно для большого...

Для приложения My Spark 2.4.x (pyspark) требуется: Входные данные - это две темы Kafka, а выходные...

Чтение этой статьи выясняется, что Spark Streaming предоставляет функцию Создание закладок : Когда...

У меня есть несколько потоков (N), которые должны обновить один и тот же кеш.Итак, предположим, что...

Привет, ребята, у меня следующая проблема. Я использую Apache Spark Streaming v1.6.0 с Java, чтобы...

Я пытаюсь написать Stream, используя опцию добавления, но получаю ошибку. Код: from pyspark.sql...

Я делаю Spark Streaming для анализа некоторых сообщений kafka в режиме реального времени. Прежде...

Я использую SparkStreaming-Kafka и хочу поддержать поиск в режиме реального времени ElasticSearch с...

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

Я установил сокет-соединение с моим SparkSession, который отправляет строку .csv-файла в мой поток....

Я пользуюсь pyspark 2.3.Мне нужно прочитать поток данных и, в конце концов, записать его в Oracle.Я...

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

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

Spark 2.4.0 поддерживает Python UDF с режимом непрерывной обработки? В моем простом коде я...

Я пытаюсь выполнить в реальном времени ввод данных Kafka в HBase через PySpark в соответствии с...

У меня есть задание Spark Streaming, которое при запуске запрашивает Hive и создает объект Map [Int...