У меня есть искровой фрейм данных (12 м x 132), и я пытаюсь рассчитать количество уникальных...

Исключительное задание, генерирующее исключение нулевого указателя при чтении данных. Я беру...

Короче, у меня есть две таблицы: (1) pharmacy_claims (столбцы: user_id, date_service, claim_id,...

Вместо того, чтобы упорядочивать по дням, это упорядочивать по месяцам. Я пробовал str_to_date, но...

У меня есть пакет документов json, который соответствует изменению базы данных .. который похож на...

Я в Windows 10 пытаюсь несколько раз прочитать текстовые строки, отделенные '\n' от...

Элемент списка Необходимо сравнить два кадра данных и создать третий кадр данных, чтобы...

Я пытаюсь настроить автономный искровой кластер на 2 компьютерах в сети моей организации. Обе...

Только что обнаружил эту ошибку при тестировании некоторых функций Spark, пытаясь построить данные...

Я хочу сделать Spark Structured Streaming (Spark 2.4.x) из источника Kafka в MariaDB с Python...

Я делаю операцию, где я приводю столбцы к их типу данных. Col (c) .cast (тип данных) Когда...

Я пытаюсь прочитать таблицу Oracle с помощью JDBC и вставить данные в таблицу Hive, но все значения...

Я использую настройки, как описано на странице: Как сгенерировать файл паркета с использованием...

Я прочитал CSV-файл в pyspark dataframe. Теперь, если я применяю условия в предложении when(), он...

У меня есть pyspark Dataframe, который содержит много столбцов, в том числе столбец типа Array и...

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

Я хочу преобразовать Spark dataframe всех столбцов TIMESTAMP в столбцы String. Кто-нибудь может...

Я новичок в искре и скале. У меня есть проблема, которую я практикую. В саду есть четыре квадранта:...

Я новичок в Скале и Спарк. Я не мог понять агрегатную функцию. Мне дан следующий код, но я не...

Я настроил Spark структурированный потоковый запрос, который читает из темы Kafka. Если количество...

У меня есть спарк-кластер с одним ведущим (имя хоста: masterA) и двумя подчиненными (имена хостов:...

У меня есть две отдельные таблицы: emr и treatment. Каждая таблица имеет столбец userID и столбец...

Я работаю над фреймом данных, который выглядит следующим образом - val df = Seq( (0.0 ), (0.0 ), (0

Я использую spark для перемещения некоторых данных из одной таблицы cassandra в другую таблицу...

Когда мы пытаемся передать данные из раздела Kafka с поддержкой SSL, мы сталкиваемся с ошибкой ниже