Фрейм данных pyspark работает с несколькими столбцами динамически
Я обнаружил, что если другое приложение является типом диалога и позволяет прикоснуться к фону, то почти любое фоновое приложение будет сбой с этой ошибкой. Я думаю, нам нужно проверять каждый раз, когда транзакция выполняется, если экземпляр был сохранен или восстановлен.
0
задан pault 28 February 2019 в 18:20
поделиться
1 ответ
Вы можете использовать понимание списка с alias.
Чтобы вернуть только новые столбцы:
import pyspark.sql.functions as f
df1 = df.select(*[f.sum(c).alias("total_"+c) for c in df.columns])
И если вы хотите сохранить существующие столбцы:
df2 = df.select("*", *[f.sum(c).alias("total_"+c) for c in df.columns])
0
ответ дан pault 28 February 2019 в 18:20
поделиться
Другие вопросы по тегам: