Вопросы по теме 'spark-dataframe'
Pyspark Dataframe TypeError: ожидаемая строка или буфер
Я создаю новый столбец для существующего фрейма данных в Pyspark, выполняя поиск в одном из поданных «скриптов» и возвращая совпадение в качестве записи для нового столбца.
import re as re
def sw_fix(data_str):
if...
1163 просмотров
schedule
09.03.2024
Разделение столбца на несколько столбцов с помощью Spark SQL
У меня есть столбец col1 , который представляет формат координат GPS:
25 4.1866N 55 8.3824E
Я хотел бы разбить его на несколько столбцов на основе пробела в качестве разделителя, как в примере вывода table_example ниже:
| 1st_split...
4201 просмотров
schedule
08.05.2024