新统计

eda/feededa/src/main/scala/com/gmei/testt.scala

@@ -65,20 +65,23 @@ object testt {
 //      )
 ////      agency_id.show()
 //      agency_id.createOrReplaceTempView("agency_id")
+      val a = Array("message_home","my_favor","my_order","order_detail","organization_detail","other_homepage")
+      for (i <- 0 until a.length){
+        val diary_pv = sc.sql(
+          s"""
+             |select partition_date,count(cl_id)
+             |from online.tl_hdfs_maidian_view
+             |where action="page_view"
+             |and params["page_name"]="diary_detail"
+             |and params["referrer"]='${a(i)}'
+             |and partition_date >='20181120'
+             |GROUP BY partition_date
+             |order by partition_date
+           """.stripMargin
+        )
+        diary_pv.show()
+      }
 
-      val diary_pv = sc.sql(
-        s"""
-           |select partition_date,count(cl_id)
-           |from online.tl_hdfs_maidian_view
-           |where action="page_view"
-           |and params["page_name"]="diary_detail"
-           |and params["referrer"]='hospital_all_cases'
-           |and partition_date >='20181120'
-           |GROUP BY partition_date
-           |order by partition_date
-         """.stripMargin
-      )
-      diary_pv.show()
 
 
 //      GmeiConfig.writeToJDBCTable(view_count, "avg", SaveMode.Overwrite)