Мы используем искру для обработки некоторого ввода от AWS SQS.В ходе процесса достигнут тайм-аут...

Я пытаюсь получить пример работы kafka и spark-streaming, и у меня возникают проблемы при запуске...

У нас есть Spark Streaming Application, работающий на Spark 2.3.3 По сути, он открывает поток...

Я хочу извлечь данные story_metrics из API Instagram с помощью pyspark и загрузить их в хранилище...

Я создаю Spark Streaming Application и хочу обрабатывать каждое сообщение Кафки отдельно. Сейчас я...

Я использую StreamingLinearRegressionWithSGD на Apache Spark, и вот мой частичный код: model =...

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

Я обрабатываю сообщения kafka и вставляю их в таблицу kudu, используя потоковую обработку с...

Я использую spark 2.4.0, используя python. и прочитайте данные из kafka_2.11-2.0.0 (бинарный не...

Я использую spark 2.4.0, используя python.и читать данные из kafka_2.11-2.0.0 (двоичный файл не...

Я пытаюсь создать Kafka Data Ingestion в HBase через PySpark. В данный момент я пытаюсь вставить...

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

Можно ли достичь ровно одного раза, обратившись к теме Кафки в приложении Spark Streaming? Для...

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

У нас есть данные (статические) с (приблизительно) 20M строками и 50,000 столбцами. Это редкие...

У меня есть специальный приемник JMS для свечей и данные, опубликованные третьей стороной. В...

Я обязан использовать <dependency> <groupId>org.apache.spark</groupId>...

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

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

Я пытаюсь транслировать данные из Твиттера о различных предметах: музыке, политике, спорте и т. Д.,...

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

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

Я пытаюсь объединить два JavaPairDStream в JavaPairDStream с помощью метода JavaStreamingContext

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

Когда я запускал spark-shell следующей командой bin / spark-shell --packages org.apache.bahir:...