Вопросы с тегом искра-структурированное-потокового

0 голосов

2 ответов

writeStream () печатает нулевые значения в пакетных данных, даже если я предоставляю правильные json данные в kafka через writeStream ()

sathvik vutukuri / 23 апреля 2020

0 голосов

0 ответов

Пустой выходной набор структурированных потоковых данных в файл или консоль

NIK_NAME / 20 апреля 2020

0 голосов

1 ответ

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

Alejandra / 10 апреля 2020

0 голосов

1 ответ

Обнаружена ошибка NoClassDefFoundError при интеграции структурированного потокового вещания Kafka-Spark через PySpark

Ashwin S / 08 апреля 2020

0 голосов

1 ответ

Можно ли сбрасывать / контролировать промежуточное состояние в структурированной потоковой передаче Spark в режиме полного вывода? (Спарк 2.4.0)

WebDev930 / 06 марта 2020

0 голосов

1 ответ

Почему Spark не сериализуемое исключение возникает при смене RDD на DataFrame?

Litchy / 03 марта 2020

0 голосов

2 ответов

Как сохранить записи, которые отбрасываются водяными знаками при потоковой структуризации

roy bapy / 26 февраля 2020

0 голосов

1 ответ

Множественные агрегации и отличная функция в Spark структурированной потоковой передаче

Aslan Bayramkulov / 21 февраля 2020

0 голосов

1 ответ

Внутреннее соединение с потоковыми данными

Himanshu Tanwani / 19 февраля 2020

0 голосов

1 ответ

Ведение временной метки последовательности входящих потоковых данных

Himanshu Tanwani / 18 февраля 2020

0 голосов

0 ответов

потоковая структура искры с efs вызывает задержку в работе

Vishnu Gopal Singhal / 15 февраля 2020

0 голосов

0 ответов

pyspark. sql .utils.AnalysisException: не удалось найти источник данных: kafka

el abed houssem / 14 февраля 2020

0 голосов

1 ответ

Как декодировать байт [] списка <Objects>в набор данных <Row>в искре?

Shyam / 07 февраля 2020

0 голосов

3 ответов

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

user37143 / 07 февраля 2020

0 голосов

0 ответов

спарк как я могу убедиться что все сообщения пишутся на кафку и тогда устанавливается только смещение

JDev / 31 января 2020

0 голосов

0 ответов

Spark SQL Преобразование не возвращает данных (структурированный поток)

ArkoD / 20 января 2020

1 голос

1 ответ

Spark Structured Streaming foreachBatch и UPSERT (объединение): сохранять или не сохранять?

Yurii Oleynikov / 19 января 2020

0 голосов

0 ответов

Как реализовать «getPreferredLocations» в источнике данных v2?

Venus / 18 января 2020

0 голосов

2 ответов

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

Hong / 13 января 2020

0 голосов

1 ответ

Как обновлять sh фрейм метаданных в потоковом приложении каждые 5 минут?

Shyam / 08 января 2020

0 голосов

1 ответ

Ищите docker изображение для контейнерных потоков моих искр scala потоковых заданий

JDev / 07 января 2020

0 голосов

1 ответ

Как добавить столбец current_timestamp () в потоковый фрейм данных?

Sarthak Pundir / 07 января 2020

1 голос

2 ответов

Как выбрать столбцы на основе значения столбца?

JDev / 06 января 2020