Как поместить переменную в pyspark groupby agg запрос - PullRequest
0 голосов
/ 26 июня 2019

Привет У меня есть запрос, в котором я хочу поместить переменные данные в группу по запросу

i Попробовал так, но он не работает

dd2=(dd1.groupBy("hours").agg({'%s':'%s'})%(columnname1,input1))

В столбце name1 содержится 'total'и input1 содержат тип агрегации, такой как mean или stddev.я хочу, чтобы этот запрос был динамическим.

1 Ответ

0 голосов
/ 28 июня 2019

Попробуйте это,

dd2=(dd1.groupBy("hours").agg({'{}'.format(columnname1):'{}'.format(input1)}))
...