如何在 pyspark groupby agg 查询中放置变量

Question

你好我有一个查询，我想通过查询将变量数据放入组中

我这样试过但没用

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

在 columnname1 中包含 'total' 并且 input1 包含需要什么样的聚合，如 mean 或 stddev。我希望这个查询是动态的。

Answer 1

试试这个，

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

How to Place a variable in pyspark groupby agg query