我想用sparkSQL计算宝马所有年份(time)的平均价格(Aprice)代码和报错结果如下:
val resultbm1 = spark.sql("select time,round(AVG(price),2) as Aprice from cars group by time where keyword = '宝马' ")
请问该怎么改呢?
我想用sparkSQL计算宝马所有年份(time)的平均价格(Aprice)代码和报错结果如下:
val resultbm1 = spark.sql("select time,round(AVG(price),2) as Aprice from cars group by time where keyword = '宝马' ")
“Devil组”引证GPT后的撰写:
val resultbm1 = spark.sql("SELECT time, ROUND(AVG(price), 2) AS Aprice FROM cars WHERE keyword = '宝马' GROUP BY time")