SparkSQL實戰7——綜合實戰完成日誌分析3

需求:按地市統計主站最受歡迎的TopN課程 //按照地市進行統計TopN課程 def cityAccessTopNStat(spark:SparkSession,accessDF:DataFrame):Unit = { //使用DataFrame方式進行統計 import spark.implicits._ val cityAccessT
相關文章
相關標籤/搜索