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

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

Я использую Spark Structured Streaming для чтения из темы Kafka. Без какого-либо раздела...

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

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

Работа Spark Streaming - чтение событий из занятой темы кафки. Чтобы понять, сколько данных...

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

У меня есть скрипт Azure Databricks в Python, который читает сообщения JSON из Event Hub с...

Привет, я столкнулся с проблемой при чтении файла журнала приложения из Windows через Apache Flume

Я могу прочитать поток из темы Кафки и записать (преобразованные) данные обратно в другую тему...

1-Проблема У меня есть программа Spark , в которой используется Kryo , но не как часть Механика...

У меня есть список больших двоичных объектов (wasbs url) в структурированном фрейме потоковых...

У меня есть случай, когда в NoSQL Datastore хранится около 150 миллионов записей.Каждый день может...

Я реализовал потребитель Kafka в PySpark (Spark 2.2.1) Я использую технологию структурированной...

Я пытаюсь сделать левое внешнее соединение между двумя Kafka Stream, используя PySpark и Structured...

Я пытался использовать Kafka, используя Spark, а точнее PySpark и Structured Streaming. import os...