Вопросы с тегом pyspark-apache--kafka

0 голосов

1 ответ

Чтение метки времени с использованием DStream API в Spark Straming от Kafka

Boni García / 30 апреля 2020

0 голосов

0 ответов

Невозможно интегрировать pyspark 3.0.0-preview2 с kafka

INT_MAX / 21 апреля 2020

1 голос

1 ответ

Ошибка при запуске spark-submit в скрипте pyspark для чтения потока kafka

K. Millan / 15 апреля 2020

0 голосов

0 ответов

Spark Streaming - автоматический сброс смещения Kafka (Spark 2.4.5, kafka 0.8.2)

ponthu / 13 апреля 2020

0 голосов

1 ответ

java .lang.ClassCastException: java .lang.Integer не может быть приведен к org. apache .spark. sql .catalyst.expressions.UnsafeRow

Alejandra / 10 апреля 2020

1 голос

1 ответ

Получение: Ошибка импорта модулей Spark: нет модуля с именем «pyspark.streaming.kafka»

Reeja / 12 февраля 2020

1 голос

1 ответ

Кафка createDirectStream с использованием PySpark

Soumya / 12 февраля 2020

0 голосов

3 ответов

Kafka-pyspark Потоковая передача: KafkaException: не удалось построить потребитель kafka

user37143 / 07 февраля 2020

0 голосов

2 ответов

Как я могу преобразовать столбец df [JSON_Format] в несколько столбцов в PySpark?

Hong / 13 января 2020

0 голосов

1 ответ

Spark Structred Streaming Pyspark Sink Csv не добавляет

Serkan şengönül / 11 января 2020

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

...