user-defined-functions ×1
Создан 24.04.2025
0
голоса
2
ответов
22
просмотров
Применение UDF в GroupedData в PySpark (с работающим примером на Python)

У меня есть следующий код на Python, который работает локально с использованием DataFrame из библиотеки pandas:

df_result = pd.DataFrame(df
                          .groupby('A')
                          .apply(lambda x: myFunction(zip(x.B, x.C), x.name))

Я хотел бы запустить этот...