Я просмотрел множество примеров для чтения данных JSON из темы Кафа. Мне удалось сделать это...

Я хочу читать и писать, используя структурированную потоковую передачу в Confluent Cloud. Проблема...

Я хочу записать данные структурной потоковой передачи в Cassandra с помощью PySpark API...

Я использую искру для записи данных в kafka таким способом. df.write (). Формат ( "Кафка"). save ()...

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

Для данного сценария я хочу отфильтровать наборы данных в структурированной потоковой передаче в...

Я не могу подключиться к kafka_2.12-2.3.0 из структурированной потоковой передачи spark_2.4.4,...

Я пытаюсь прочитать записи из темы Kafka, используя приведенный ниже фрагмент кода: ds_raw = (spark...

Я использую spark-sql 2.4.1, spark-cassandra-connector_2.11-2.4.1.jar и java8. При вставке данных...

Когда я тестирую, мой код выглядит следующим образом. .format("kafka")

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