У меня есть кадр данных, как показано ниже: ---------------------+------------------------ text |...

Я хочу добавить имя файла к каждой строке при вставке в БД. Получение папки в качестве ввода....

У меня есть список строк в Python.Я создал из него блок данных с одним столбцом с таким кодом:...

Мой dataframe завершается ошибкой из-за NumberFormatException в одном из вложенных полей JSON при...

Когда я отправляю задание на машине с набором машин, расположенной в лондонском часовом поясе,...

Нужна помощь в сортировке по ключу после вывода groupByKey: val skuRDD2:RDD[(String...

Можно ли добавить новый столбец в существующую таблицу искр с помощью команды ALTER TABLE? var...

Попытка понять, как разделы Hive связаны с разделами Spark, завершается вопросом о соединениях. У...

Я пытаюсь использовать функцию createSataframe для sparksession, и я продолжаю получать сообщение...

У меня есть фрейм данных df +----------+----+----+----+---+---+----+---+---+-------+-------+ |...

Я пытаюсь изменить мой JavaRDD из String на JavaRDD из Row.На шаге я меняю строку на строку

Получение неправильного результата на счету. +--------+ |count(1)| +--------+ | 0| // Should not be...

У меня есть требование для создания XML, который имеет структуру ниже <parent>...

Тест, использующий spark-sql, не выполнен из-за следующей ошибки: Коррелированные скалярные...

Я пытаюсь понять концепции Spark SQL и мне интересно, могу ли я использовать Spark SQL в качестве...