Приложение My Spark обрабатывает сообщения от Кафки и записывает их в Cassandra.Через 3 часа...
У меня есть приложение Spark Streaming (v 2.4.0), которое выводит данные в формате паркета на...
Не удалось выполнить задание My Spark Streaming со следующим исключением Диагностика: Контейнер...
При использовании Spark Cassandra Connector все потоковые данные всегда вставляются в базу данных...
Я пытаюсь подключить тему Kafak, в которой используется Avro, к Spark Stream.Я пытаюсь использовать...
У нас есть поток Кафка, который использует Avro.Мне нужно подключить его к Spark Stream, используя...
Поскольку преобразования в искре лениво оцениваются, есть ли способ, как мы можем выполнить...
Я пишу приложение Spark Streaming, в котором входные данные помещаются в корзину S3 небольшими...
Я пишу потоковое приложение с использованием pyspark, которое в основном обрабатывает данные....
Я передавал данные из тем Кафки с помощью Spark.Это код, который я пробовал.Здесь я просто...
Я хочу для потоковой передачи данных, используя спарк из темы Кафки в Horton works. Я запустил...