Я пытаюсь преобразовать список пользовательских объектов Java в пользовательский типизированный...

Задержка планирования увеличивается при получении сообщений из IBM MQ. Привет У меня есть...

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

Я попытался прочитать xml-файл с помощью spark и превратить его в массив JavaRDD.Я читал о том, как...

Я хочу сохранить индексы Elasticsearch в файлах HDFS, не используя ES-Hadoop Connector.Предлагаемое...

У меня есть приложение Spark Streaming в Java, которое читает записи из потока kineses (1 осколок)...

Я думал, что смогу просто сделать final JavaPairDstream<String, Integer> y = ... ; final...

Я использую Spark 2.3.1 и язык программирования как Java 8. Пытаюсь подключиться к Твиттеру и...

У меня есть JavaPairDStream<String, Tuple2<Double, Double>> со значениями, (ADBE,(1.1,1

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

Я читаю данные из S3 с использованием Spark Streaming и хочу обновить потоковые данные в Amazon...

Я пытаюсь реализовать простой пример подсчета слов для sparkStreaming, прослушивая localhost:9999 и...

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

Я получаю потоковый набор данных из концентраторов событий Azure. Данные поступают в следующем...

У нас есть DStreams, который использует сообщения JSON, используя пользовательский получатель. Это...