利用Spark SQL分析用户消费行为

Question

1.
val df=spark.read.format("csv").load(f)

2.
df.createOrReplaceTempView(“v_user”)

3.
df1=spark.sql(“select subject,avg(grade) from v_user group by subject”)

4.
df1.show()
df1.write.save()