SparkSQL实战7——综合实战完成日志分析3

需求：按地市统计主站最受欢迎的TopN课程 //按照地市进行统计TopN课程 def cityAccessTopNStat(spark:SparkSession,accessDF:DataFrame):Unit = { //使用DataFrame方式进行统计 import spark.implicits._ val cityAccessT

>>阅读原文<<