Я создаю ниже KafkaDirectStream. val messages = KafkaUtils.createDirectStream[String, String]( ssc,...

У меня на Месосе работает потоковая передача искр.Все его партии занимают одно и то же время, и это...

У меня есть два структурированных потоковых приложения Spark.Первый делает несколько оконных...

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

У меня есть приложение Spark Streaming, которое записывает свои выходные данные в HDFS. Какие меры...

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

Я работаю над проектом Stream Streaming, который берет данные из Kafka, применяет некоторые правила...

Я новичок в Spark-Streaming и Kafka.С помощью следующего кода я могу использовать сообщения Кафки,...

Я пытаюсь найти трендовые хэштеги в твиттере, используя потоковую передачу Spark. os -> mac os...

Есть ли репозиторий github, где я могу интегрировать свой потоковый код pySpark Spark с PowerBI?И я...

Я получаю следующее сообщение об ошибке: Exception in thread "main" java.lang

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

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

Я пытаюсь поэкспериментировать с группами потребителей Вот мой фрагмент кода public final class App...

У меня есть потоковое приложение SPARK, которое читает непрерывные входящие данные из прямого...

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

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

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

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

Я храню данные в Kafka, используя схему реестра и сериализацию avro.Теперь я должен использовать...

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

Мне интересно, как разделы Kafka распределяются между SimpleConsumer, запускаемым из...

Я работаю над ручным управлением смещением в Кафке, используя spark-streaming-kafka-0-8_2.11 org

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

У меня есть процесс-демон, который выгружает данные в виде файлов в HDFS. Мне нужно создать RDD...